Skip to content

Commit

Permalink
Include success caveats in pipetask report tables.
Browse files Browse the repository at this point in the history
  • Loading branch information
TallJimbo committed Jan 14, 2025
1 parent 742cebb commit faadf70
Showing 1 changed file with 14 additions and 1 deletion.
15 changes: 14 additions & 1 deletion python/lsst/ctrl/mpexec/cli/script/report.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@

from astropy.table import Table
from lsst.daf.butler import Butler
from lsst.pipe.base import QuantumGraph
from lsst.pipe.base import QuantumGraph, QuantumSuccessCaveats
from lsst.pipe.base.execution_reports import QuantumGraphExecutionReport
from lsst.pipe.base.quantum_provenance_graph import QuantumProvenanceGraph, Summary

Expand Down Expand Up @@ -262,11 +262,19 @@ def print_summary(summary: Summary, full_output_filename: str | None, brief: boo
"Messages": quantum_summary.messages,
}
)
if len(task_summary.caveats) > 1:
caveats = "(multiple)"
elif len(task_summary.caveats) == 1:
((code, data_ids),) = task_summary.caveats.items()
caveats = f"{code}({len(data_ids)})"
else:
caveats = ""
quanta_table.append(
{
"Task": label,
"Unknown": task_summary.n_unknown,
"Successful": task_summary.n_successful,
"Caveats": caveats,
"Blocked": task_summary.n_blocked,
"Failed": task_summary.n_failed,
"Wonky": task_summary.n_wonky,
Expand Down Expand Up @@ -294,6 +302,11 @@ def print_summary(summary: Summary, full_output_filename: str | None, brief: boo
)
quanta = Table(quanta_table)
quanta.pprint_all()
print("")
print("Caveat codes:")
for k, v in QuantumSuccessCaveats.legend().items():
print(f"{k}: {v}")
print("")
# Dataset loop
dataset_table = []
cursed_datasets = []
Expand Down

0 comments on commit faadf70

Please sign in to comment.