[arvados] updated: 2.6.0-264-gb312e6573
git repository hosting
git at public.arvados.org
Tue Jun 13 14:02:20 UTC 2023
Summary of changes:
lib/dispatchcloud/container/queue.go | 7 +++++++
1 file changed, 7 insertions(+)
via b312e657331120960dafb2e0b536f560e402486f (commit)
from b6103b727f2ffeae0d9a4702c158842df71a2128 (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
commit b312e657331120960dafb2e0b536f560e402486f
Author: Tom Clegg <tom at curii.com>
Date: Tue Jun 13 09:58:51 2023 -0400
20601: Add comment re fetch-by-uuid loop.
Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom at curii.com>
diff --git a/lib/dispatchcloud/container/queue.go b/lib/dispatchcloud/container/queue.go
index 193c3bb20..77752013e 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 {
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list