refactor(trigger): streamline workflow argument handling in DraftWorkflowTriggerNodeApi

- Simplified retrieval of workflow arguments by directly accessing event.workflow_args.
- Removed unnecessary conditional checks for user inputs, ensuring cleaner code.
- Enhanced TriggerEventNode to use deepcopy for user inputs to prevent unintended mutations.
This commit is contained in:
Harry
2025-10-29 01:04:25 +08:00
parent a264a609db
commit 5c95c77604
3 changed files with 4 additions and 9 deletions

View File

@ -118,7 +118,6 @@ class TriggerDebugEventBus:
pool_key,
address_id,
)
logger.info("event_data: %s", event_data)
return event_type.model_validate_json(json_data=event_data) if event_data else None
except RedisError:
logger.exception("Failed to poll event from pool: %s", pool_key)

View File

@ -1,4 +1,5 @@
from collections.abc import Mapping
from copy import deepcopy
from typing import Any, Optional
from core.workflow.entities.workflow_node_execution import WorkflowNodeExecutionMetadataKey, WorkflowNodeExecutionStatus
@ -65,7 +66,7 @@ class TriggerEventNode(Node):
"""
# Get trigger data passed when workflow was triggered
inputs = dict(self.graph_runtime_state.variable_pool.user_inputs)
inputs = deepcopy(self.graph_runtime_state.variable_pool.user_inputs)
metadata = {
WorkflowNodeExecutionMetadataKey.TRIGGER_INFO: {
"provider_id": self._node_data.provider_id,