Lars/mitai-jinkendo
1
0
Fork 0
Code Issues 33 Pull Requests Actions Packages Projects Releases 5 Wiki Activity

fix: Include node_states in SSE execution_complete and execution_failed events
All checks were successful
Deploy Development / deploy (push) Successful in 54s
Details
Build Test / pytest-backend (push) Successful in 4s
Details
Build Test / lint-backend (push) Successful in 1s
Details
Build Test / build-frontend (push) Successful in 16s
Details

Browse Source 
- Serialize NodeExecutionState models to dict for JSON transmission
- Add node_states to execution_complete event for debug panel
- Add node_states to execution_failed event for partial progress visibility
- Enables WorkflowDebugPanel to display per-node debug information

Fixes: WorkflowDebugPanel not appearing due to missing node_states in SSE stream
This commit is contained in:
Lars 2026-04-13 13:05:11 +02:00
parent 0a27533262
commit d3c28a6ee9
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
backend/workflow_executor.py
View File

@ -216,6 +216,7 @@ async def execute_workflow(
"execution_id": execution_id, "execution_id": execution_id,
"status": "completed", "status": "completed",
"aggregated_result": aggregated, "aggregated_result": aggregated,
"node_states": [ns.model_dump() for ns in node_states], # Serialize Pydantic models
"total_nodes": len(node_states), "total_nodes": len(node_states),
"completed_nodes": len([ns for ns in node_states if ns.status == NodeStatus.EXECUTED]), "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]), "skipped_nodes": len([ns for ns in node_states if ns.status == NodeStatus.SKIPPED]),
@ -238,12 +239,16 @@ async def execute_workflow(
# NEW: Progress-Callback für Fehler # NEW: Progress-Callback für Fehler
if progress_callback: if progress_callback:
await progress_callback("execution_failed", { error_data = {
"execution_id": execution_id, "execution_id": execution_id,
"status": "failed", "status": "failed",
"error": str(e), "error": str(e),
"completed_at": datetime.utcnow().isoformat() "completed_at": datetime.utcnow().isoformat()
}) }
# Include node_states if available (to show partial progress)
if 'node_states' in locals() and node_states:
error_data["node_states"] = [ns.model_dump() for ns in node_states]
await progress_callback("execution_failed", error_data)
# Speichere Failed State # Speichere Failed State
completed_at = datetime.utcnow().isoformat() completed_at = datetime.utcnow().isoformat()