From 24fa5f33d7a452973052241ae027adf133c771df Mon Sep 17 00:00:00 2001 From: Harry Date: Wed, 22 Oct 2025 15:36:48 +0800 Subject: [PATCH] fix(trigger): update input handling in TriggerEventNode to correctly retrieve and set outputs --- .../nodes/trigger_plugin/trigger_event_node.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py b/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py index 9424192942..adb46280c7 100644 --- a/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py +++ b/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py @@ -63,11 +63,14 @@ class TriggerEventNode(Node): """ # Get trigger data passed when workflow was triggered - trigger_inputs = dict(self.graph_runtime_state.variable_pool.user_inputs.get("inputs", {})) + inputs = dict(self.graph_runtime_state.variable_pool.user_inputs) + + # The event already ran before workflow execution, so we can get the outputs from the inputs + outputs = inputs.get("inputs", {}) metadata = { WorkflowNodeExecutionMetadataKey.TRIGGER_INFO: { - **trigger_inputs, + **inputs, "provider_id": self._node_data.provider_id, "event_name": self._node_data.event_name, "plugin_unique_identifier": self._node_data.plugin_unique_identifier, @@ -75,7 +78,7 @@ class TriggerEventNode(Node): } return NodeRunResult( status=WorkflowNodeExecutionStatus.SUCCEEDED, - inputs=trigger_inputs, - outputs=trigger_inputs, + inputs=inputs, + outputs=outputs, metadata=metadata, )