fix: error in obtaining end_to_node_id during conditional parallel execution (#13673)

2025-02-13 18:00:28 +08:00 · 2025-02-13 18:00:28 +08:00 · f0b9257387
commit f0b9257387
parent c398c9cb6a
1 changed files with 0 additions and 2 deletions
--- a/api/core/workflow/graph_engine/entities/graph.py
+++ b/api/core/workflow/graph_engine/entities/graph.py
@ -590,8 +590,6 @@ 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] = []