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 0dce41f1f9..7b7e634e0f 100644 --- a/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py +++ b/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py @@ -66,10 +66,6 @@ class TriggerEventNode(Node): # Get trigger data passed when workflow was triggered 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: { **inputs, @@ -81,6 +77,6 @@ class TriggerEventNode(Node): return NodeRunResult( status=WorkflowNodeExecutionStatus.SUCCEEDED, inputs={}, - outputs=outputs, + outputs=inputs, metadata=metadata, )