X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/a4fa040579473b598a532ee38173b1a28c6b1694..2b952ed950affd0904da21e2dc7c7bf5cdd7d1ce:/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..148b653c2e 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,11 +43,6 @@ 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