diff --git a/api/core/app/task_pipeline/workflow_cycle_manage.py b/api/core/app/task_pipeline/workflow_cycle_manage.py index dcc364d227..ad29201df3 100644 --- a/api/core/app/task_pipeline/workflow_cycle_manage.py +++ b/api/core/app/task_pipeline/workflow_cycle_manage.py @@ -842,4 +842,4 @@ class WorkflowCycleManage: if node_execution_id not in self._workflow_node_executions: raise ValueError(f"Workflow node execution not found: {node_execution_id}") cached_workflow_node_execution = self._workflow_node_executions[node_execution_id] - return cached_workflow_node_execution + return session.merge(cached_workflow_node_execution)