Browse Source

Fix the problem of Workflow terminates after parallel tasks execution, merge node not triggered (#12498)

Co-authored-by: Novice Lee <novicelee@NoviPro.local>
Lazy_Frog 2 months ago
parent
commit
b7c11c1818
1 changed files with 2 additions and 0 deletions
  1. 2 0
      api/core/workflow/graph_engine/entities/graph.py

+ 2 - 0
api/core/workflow/graph_engine/entities/graph.py

@@ -590,6 +590,8 @@ class Graph(BaseModel):
                             start_node_id=node_id,
                             routes_node_ids=routes_node_ids,
                         )
+                        # Exclude conditional branch nodes
+                        and all(edge.run_condition is None for edge in reverse_edge_mapping.get(node_id, []))
                     ):
                         if node_id not in merge_branch_node_ids:
                             merge_branch_node_ids[node_id] = []