diff --git a/scheduler/generic_sched.go b/scheduler/generic_sched.go index e6df9a526..3a3db34d8 100644 --- a/scheduler/generic_sched.go +++ b/scheduler/generic_sched.go @@ -216,6 +216,9 @@ func (s *GenericScheduler) process() (bool, error) { if !fullCommit { s.logger.Printf("[DEBUG] sched: %#v: attempted %d placements, %d placed", s.eval, expected, actual) + if newState == nil { + return false, fmt.Errorf("missing state refresh after partial commit") + } return false, nil }