opensource
/
dify
mirror of https://github.com/langgenius/dify.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refactor(graph_engine): Remove unnecessary check from SkipPropagator 

Signed-off-by: -LAN- <laipz8200@outlook.com>
This commit is contained in:
-LAN- 2025-08-28 04:45:26 +08:00
parent 1d377fe994
commit ef21097774
No known key found for this signature in database
GPG Key ID: 6BA0D108DED011FF
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
api/core/workflow/graph_engine/graph_traversal/skip_propagator.py
View File

@ -2,7 +2,9 @@
Skip state propagation through the graph.
"""
from core.workflow.graph import Graph
from collections.abc import Sequence
from core.workflow.graph import Edge, Graph
from ..state_management import EdgeStateManager, NodeStateManager
@ -57,9 +59,8 @@ class SkipPropagator:
# If any edge is taken, node may still execute
if edge_states["has_taken"]:
# Check if node is ready and enqueue if so
if self.node_state_manager.is_node_ready(downstream_node_id):
self.node_state_manager.enqueue_node(downstream_node_id)
# Enqueue node
self.node_state_manager.enqueue_node(downstream_node_id)
return
# All edges are skipped, propagate skip to this node