get_failed_steps_for_fileset

coffea.dataset_tools.get_failed_steps_for_fileset(fileset: Dict[str, DatasetSpec], report_dict: dict[str, Array])

Modify an input dataset to only contain the files and row-ranges for failed processing jobs as specified in the supplied report. :param fileset: The set of datasets to be reduced to only contain files and row-ranges that have previously encountered failed file access. :type fileset: FilesetSpec :param report_dict: The computed file-access error reports from dask-awkward, indexed by dataset name. :type report_dict: dict[str, awkward.Array]

Returns:

out – The reduced dataset with only the row-ranges and files that failed processing, according to the input report.

Return type:

FilesetSpec