perf(workflow): update standard node output structure

2026-01-26 12:28:40 +08:00
parent 1fc04c37d3
commit 85681db7b7
1 changed files with 3 additions and 1 deletions
--- a/api/app/core/workflow/executor.py
+++ b/api/app/core/workflow/executor.py
@@ -368,7 +368,9 @@ class WorkflowExecutor:
                                "timestamp": int(datetime.datetime.fromisoformat(
                                    data.get("timestamp")
                                ).timestamp() * 1000),
-                                "state": result.get("node_outputs", {}).get(node_name),
+                                "input": result.get("node_outputs", {}).get(node_name, {}).get("input"),
+                                "output": result.get("node_outputs", {}).get(node_name, {}).get("output"),
+                                "elapsed_time": result.get("node_outputs", {}).get(node_name, {}).get("elapsed_time"),
                            }
                        }