diff --git a/core/blockstm/status.go b/core/blockstm/status.go index 7a5c895b7e..3025cf6c3e 100644 --- a/core/blockstm/status.go +++ b/core/blockstm/status.go @@ -128,7 +128,7 @@ func (m *taskStatusManager) addDependencies(blocker int, dependent int) bool { // Blocker has already completed delete(curblockers, blocker) - return false + return len(curblockers) > 0 } if _, ok := m.dependency[blocker]; !ok {