summarize_dag

lsst.ctrl.bps.htcondor.summarize_dag(dir_name: str) → tuple[str, dict[str, str], dict[str, WmsNodeType]]

Build bps_run_summary string from dag file.

Parameters

dir_namestr

Path that includes dag file for a run.

Returns

summarystr

Semi-colon separated list of job labels and counts (Same format as saved in dag classad).

job_name_to_labeldict [str, str]

Mapping of job names to job labels.

job_name_to_typedict [str, lsst.ctrl.bps.htcondor.WmsNodeType]

Mapping of job names to job types (e.g., payload, final, service).