diff --git a/main.py b/main.py index f903108..4d10b87 100644 --- a/main.py +++ b/main.py @@ -694,7 +694,7 @@ def run_dag(req: DagRequest): store = get_store() log_dag_execution(dag_id=req.session_id, agent_results=results, total_duration_s=total_dur) store.push(AGENT_ID, "last_dag_total_duration_s", total_dur) - store.push(AGENT_ID, "last_dag_agent_count", len(agents)) + store.push(AGENT_ID, "last_dag_agent_count", len(agent_ids)) store.push(AGENT_ID, "last_dag_success_count", sum(1 for r in results if r["success"])) return {