From 6df520ebc6159193752eee4ca0797572f3e42e4a Mon Sep 17 00:00:00 2001 From: takatost Date: Sat, 16 Mar 2024 14:45:16 +0800 Subject: [PATCH] add skip ran node --- api/core/workflow/workflow_engine_manager.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/api/core/workflow/workflow_engine_manager.py b/api/core/workflow/workflow_engine_manager.py index a7379e6e99..99373de393 100644 --- a/api/core/workflow/workflow_engine_manager.py +++ b/api/core/workflow/workflow_engine_manager.py @@ -137,6 +137,12 @@ class WorkflowEngineManager: if not next_node: break + # check is already ran + if next_node.node_id in [node_and_result.node.node_id + for node_and_result in workflow_run_state.workflow_nodes_and_results]: + predecessor_node = next_node + continue + has_entry_node = True # max steps 30 reached