outman/dify
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge 7cbaef6d68 into a30945312a

Browse Source
This commit is contained in:
liuzhenghua 2025-03-21 15:09:15 +08:00 committed by GitHub
commit f3fa42e71b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
api/core/workflow/graph_engine/graph_engine.py
View File

@ -435,6 +435,12 @@ class GraphEngine:
next_node_id = final_node_id next_node_id = final_node_id
if in_parallel_id and self.graph.node_parallel_mapping.get(next_node_id, "") != in_parallel_id: if in_parallel_id and self.graph.node_parallel_mapping.get(next_node_id, "") != in_parallel_id:
source_edges = self.graph.reverse_edge_mapping.get(next_node_id, [])
source_node_ids = {edge.source_node_id for edge in source_edges}
if len(source_node_ids) == 1:
# if -> node1, node2, else -> node2. the current path follows the else branch.
in_parallel_id = self.graph.node_parallel_mapping.get(next_node_id, "")
else:
break break
def _run_parallel_branches( def _run_parallel_branches(