X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/43ad590772de48fbc3a6a45654445bab79a0bdc1..4eb591b3d541cc5ac035fb0eed7c39dc8e81dd02:/lib/dispatchcloud/scheduler/fix_stale_locks.go?ds=sidebyside

diff --git a/lib/dispatchcloud/scheduler/fix_stale_locks.go b/lib/dispatchcloud/scheduler/fix_stale_locks.go
index 4bd27021c6..dbd8b609a9 100644
--- a/lib/dispatchcloud/scheduler/fix_stale_locks.go
+++ b/lib/dispatchcloud/scheduler/fix_stale_locks.go
@@ -7,8 +7,8 @@ package scheduler
 import (
 	"time"
 
-	"git.curoverse.com/arvados.git/lib/dispatchcloud/worker"
-	"git.curoverse.com/arvados.git/sdk/go/arvados"
+	"git.arvados.org/arvados.git/lib/dispatchcloud/worker"
+	"git.arvados.org/arvados.git/sdk/go/arvados"
 )
 
 // fixStaleLocks waits for any already-locked containers (i.e., locked
@@ -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 {