fix(workflow): remove edges for unreachable nodes in graph

2026-03-24 15:17:01 +08:00
parent 3dc863cabf
commit b739b032d9
1 changed files with 2 additions and 0 deletions
--- a/api/app/core/workflow/engine/graph_builder.py
+++ b/api/app/core/workflow/engine/graph_builder.py
@@ -390,6 +390,8 @@ class GraphBuilder:
        for edge in self.edges:
            source = edge.get("source")
            target = edge.get("target")
+            if source not in self.reachable_nodes or target not in self.reachable_nodes:
+                continue
            condition = edge.get("condition")
            edge_type = edge.get("type")