X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/a4396e183ec11a7241cf5089c5ccfbca1ad8627f..cd020c016106fbe844501c5f434c16f4def4e08d:/lib/dispatchcloud/scheduler/fix_stale_locks.go

diff --git a/lib/dispatchcloud/scheduler/fix_stale_locks.go b/lib/dispatchcloud/scheduler/fix_stale_locks.go
index 4bd27021c6..1f9338f7b8 100644
--- a/lib/dispatchcloud/scheduler/fix_stale_locks.go
+++ b/lib/dispatchcloud/scheduler/fix_stale_locks.go
@@ -23,7 +23,7 @@ func (sch *Scheduler) fixStaleLocks() {
 	var stale []string
 	timeout := time.NewTimer(sch.staleLockTimeout)
 waiting:
-	for {
+	for sch.pool.CountWorkers()[worker.StateUnknown] > 0 {
 		running := sch.pool.Running()
 		qEntries, _ := sch.queue.Entries()
 
@@ -43,16 +43,10 @@ waiting:
 
 		select {
 		case <-wp:
-			// Stop waiting if all workers have been
-			// contacted.
-			if sch.pool.CountWorkers()[worker.StateUnknown] == 0 {
-				break waiting
-			}
 		case <-timeout.C:
 			// Give up.
 			break waiting
 		}
-
 	}
 
 	for _, uuid := range stale {