[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