fix: Update workflow executor to set outputs for input nodes

PySpur-Dev · Feb 12, 2025 · a57f77b · a57f77b
1 parent 47f6c6b
commit a57f77b
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/backend/app/execution/workflow_executor.py b/backend/app/execution/workflow_executor.py
@@ -359,6 +359,13 @@ async def run(
             ),
         )
         self._initial_inputs[input_node.id] = input
+        # also update outputs for input node
+        input_node_obj = NodeFactory.create_node(
+            node_name=input_node.title,
+            node_type_name=input_node.node_type,
+            config=input_node.config,
+        )
+        self._outputs[input_node.id] = await input_node_obj(input)
 
         nodes_to_run = set(self._node_dict.keys())
         if node_ids: