X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/61b45d1413d21a4f6a0fd6449680f0d03eac1d88..e44725a3792df227f189f88ffb2cd1dbf0e93489:/lib/dispatchcloud/container/queue.go diff --git a/lib/dispatchcloud/container/queue.go b/lib/dispatchcloud/container/queue.go index 193c3bb200..77752013e8 100644 --- a/lib/dispatchcloud/container/queue.go +++ b/lib/dispatchcloud/container/queue.go @@ -435,6 +435,13 @@ func (cq *Queue) poll() (map[string]*arvados.Container, error) { } apply(avail) + // Check for containers that we already know about but weren't + // returned by any of the above queries, and fetch them + // explicitly by UUID. If they're in a final state we can drop + // them, but otherwise we need to apply updates, e.g., + // + // - Queued container priority has been reduced + // - Locked container has been requeued with lower priority missing := map[string]bool{} cq.mtx.Lock() for uuid, ent := range cq.current {