roastcoffea.aggregation.workflow

Workflow-level metrics aggregation.

Calculates throughput, data rates, event rates, compression ratios, and overall timing metrics from coffea reports and tracking data.

Functions

aggregate_workflow_metrics(coffea_report, ...)

Calculate workflow metrics from Coffea report.
roastcoffea.aggregation.workflow.aggregate_workflow_metrics(coffea_report, t_start, t_end, custom_metrics=None)[source]

Calculate workflow metrics from Coffea report.

Parameters:

  • coffea_report (dict) – Coffea report from Runner

  • t_start (float) – Start time

  • t_end (float) – End time

  • custom_metrics (dict, optional) – Per-dataset custom metrics

Returns:

Workflow metrics

Return type:

dict