From 3664f53c51a3b39df8004c050265fbcc20371030 Mon Sep 17 00:00:00 2001 From: Lars Date: Mon, 13 Apr 2026 11:49:31 +0200 Subject: [PATCH] fix: Use NodeStatus.EXECUTED instead of COMPLETED NodeStatus enum has EXECUTED, not COMPLETED. Fixed in workflow_executor.py progress callback. --- backend/workflow_executor.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/backend/workflow_executor.py b/backend/workflow_executor.py index c27bf59..6e36ad4 100644 --- a/backend/workflow_executor.py +++ b/backend/workflow_executor.py @@ -179,7 +179,7 @@ async def execute_workflow( "node_label": node_label, "status": node_state.status.value, "total_nodes": len(graph.nodes), - "completed_nodes": len([ns for ns in node_states if ns.status in [NodeStatus.COMPLETED, NodeStatus.SKIPPED]]), + "completed_nodes": len([ns for ns in node_states if ns.status in [NodeStatus.EXECUTED, NodeStatus.SKIPPED]]), "error": node_state.error if node_state.status == NodeStatus.FAILED else None }) @@ -214,7 +214,7 @@ async def execute_workflow( "status": "completed", "aggregated_result": aggregated, "total_nodes": len(node_states), - "completed_nodes": len([ns for ns in node_states if ns.status == NodeStatus.COMPLETED]), + "completed_nodes": len([ns for ns in node_states if ns.status == NodeStatus.EXECUTED]), "skipped_nodes": len([ns for ns in node_states if ns.status == NodeStatus.SKIPPED]), "failed_nodes": len([ns for ns in node_states if ns.status == NodeStatus.FAILED]), "completed_at": completed_at