diff --git a/python/lsst/ctrl/mpexec/cli/script/report.py b/python/lsst/ctrl/mpexec/cli/script/report.py index 4fc973dd..913c52f8 100644 --- a/python/lsst/ctrl/mpexec/cli/script/report.py +++ b/python/lsst/ctrl/mpexec/cli/script/report.py @@ -33,9 +33,13 @@ from lsst.pipe.base.execution_reports import QuantumGraphExecutionReport -def report(butler_config: str, qgraph_uri: str, - full_output_filename: str | None, logs: bool = True, - show_errors: bool = False) -> None: +def report( + butler_config: str, + qgraph_uri: str, + full_output_filename: str | None, + logs: bool = True, + show_errors: bool = False, +) -> None: """Summarize the produced and missing expected dataset in a quantum graph. Parameters @@ -59,12 +63,6 @@ def report(butler_config: str, qgraph_uri: str, command-line along with the report. By default, these messages and their associated data ids are stored in a yaml file with format `{run timestamp}_err.yaml` in the working directory instead. - - See Also - -------- - lsst.pipe.base.QuantumGraphExecutionReport.make_reports - lsst.pipe.base.QuantumGraphExecutionReport.write_summary_yaml - lsst.pipe.base.TaskExecutionReport.to_summary_dict """ butler = Butler.from_config(butler_config, writeable=False) qgraph = QuantumGraph.loadUri(qgraph_uri) @@ -81,10 +79,15 @@ def report(butler_config: str, qgraph_uri: str, dataset_table_rows.append(summary_dict[task]["outputs"][data_product]) data_products.append(data_product) - quanta_summary.append({"Task" : task, "Failed Quanta" : summary_dict[task]["failed_quanta"], - "Blocked Quanta": summary_dict[task]["n_quanta_blocked"]}) + quanta_summary.append( + { + "Task": task, + "Failed Quanta": summary_dict[task]["failed_quanta"], + "Blocked Quanta": summary_dict[task]["n_quanta_blocked"], + } + ) - if 'errors' in summary_dict[task].keys(): + if "errors" in summary_dict[task].keys(): error_summary.append({task: summary_dict[task]["errors"]}) quanta = Table(quanta_summary) datasets = Table(dataset_table_rows)