Function aggregate_ops

src/evaluation/metrics.py:169–183

(results: list[ScenarioResult])

def aggregate_ops(results: list[ScenarioResult]) -> AggregateOps:
    if not results:
        return AggregateOps()

    durations = [r.ops.duration_ms for r in results if r.ops.duration_ms is not None]
    costs = [r.ops.est_cost_usd for r in results if r.ops.est_cost_usd is not None]

    return AggregateOps(
        tokens_in_total=sum(r.ops.tokens_in for r in results),
        tokens_out_total=sum(r.ops.tokens_out for r in results),
        duration_ms_p50=_percentile(durations, 50),
        duration_ms_p95=_percentile(durations, 95),
        tool_calls_total=sum(r.ops.tool_call_count for r in results),
        est_cost_usd_total=round(sum(costs), 6) if costs else None,
    )


def _percentile(values: list[float], pct: float) -> float | None: