Skip to content

Commit dc4e822

Browse files
author
Nick Manganelli
committed
revert slice_files in manipulations.py
1 parent b80ff90 commit dc4e822

File tree

1 file changed

+7
-9
lines changed

1 file changed

+7
-9
lines changed

src/coffea/dataset_tools/manipulations.py

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -203,20 +203,18 @@ def slice_files(fileset: FilesetSpec, theslice: Any = slice(None)) -> FilesetSpe
203203
out : FilesetSpec
204204
The reduce fileset with only the files specified by theslice left.
205205
"""
206+
if isinstance(fileset, LimitFilesProtocol):
207+
return fileset.limit_files(theslice)
208+
206209
if not isinstance(theslice, slice):
207210
theslice = slice(theslice)
208211

209212
out = copy.deepcopy(fileset)
210213
for name, entry in fileset.items():
211-
is_datasetspec = isinstance(entry, DatasetSpec)
212-
files = entry.files if is_datasetspec else entry["files"]
213-
fnames = list(files.keys())[theslice]
214-
finfos = list(files.values())[theslice]
215-
updated = {fname: finfo for fname, finfo in zip(fnames, finfos)}
216-
if is_datasetspec:
217-
out[name].files = InputFiles(updated)
218-
else:
219-
out[name]["files"] = updated
214+
fnames = list(entry["files"].keys())[theslice]
215+
finfos = list(entry["files"].values())[theslice]
216+
217+
out[name]["files"] = {fname: finfo for fname, finfo in zip(fnames, finfos)}
220218

221219
return out
222220

0 commit comments

Comments
 (0)