Fix lost start_execution after enqueue_node when the last previous node is skipped

This commit is contained in:
sai 2025-12-27 22:46:22 +08:00
parent f610f6895f
commit cb834b816c

View File

@ -60,6 +60,7 @@ class SkipPropagator:
if edge_states["has_taken"]:
# Enqueue node
self._state_manager.enqueue_node(downstream_node_id)
self._state_manager.start_execution(downstream_node_id)
return
# All edges are skipped, propagate skip to this node