fix: workflow incorrectly marked as completed while nodes are still executing (#30251)

Co-authored-by: sai <>
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
This commit is contained in:
Sai
2025-12-31 10:45:43 +08:00
committed by GitHub
parent 9007109a6b
commit 64dc98e607
3 changed files with 309 additions and 0 deletions

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