From a57f77bb42f78de6241e6c9147089b9243505f92 Mon Sep 17 00:00:00 2001 From: Srijan Patel Date: Wed, 12 Feb 2025 06:43:29 +0000 Subject: [PATCH] fix: Update workflow executor to set outputs for input nodes --- backend/app/execution/workflow_executor.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/backend/app/execution/workflow_executor.py b/backend/app/execution/workflow_executor.py index f0a53078..34b4e83f 100644 --- 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: