From 90852b4340c9b17aae24b5c0e12b9897209ed0fa Mon Sep 17 00:00:00 2001
From: Bryon Lewis <Bryon.Lewis@kitware.com>
Date: Tue, 5 May 2026 10:25:04 -0400
Subject: [PATCH] swap addons downloading to pipelines container for access

---
 docker-compose.yml                        |  2 ++
 server/dive_server/views_configuration.py | 14 +++++++++-----
 2 files changed, 11 insertions(+), 5 deletions(-)

diff --git a/docker-compose.yml b/docker-compose.yml
index 1b816e912..3365473d1 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -116,6 +116,8 @@ services:
     << : *base-worker
     profiles:
       - gpu
+    volumes:
+      - addons:/tmp/addons:rw
     build:
       context: .
       dockerfile: docker/girder_worker_gpu.Dockerfile
diff --git a/server/dive_server/views_configuration.py b/server/dive_server/views_configuration.py
index 720286fb6..b74517b95 100644
--- a/server/dive_server/views_configuration.py
+++ b/server/dive_server/views_configuration.py
@@ -182,13 +182,17 @@ def get_addons(self):
         )
     )
     def upgrade_pipelines(self, force: bool, urls: List[str]):
+        worker_capabilities.require_pipeline_worker()
         token = Token().createToken(user=self.getCurrentUser(), days=1)
         Setting().set(constants.SETTINGS_CONST_JOBS_CONFIGS, None)
-        tasks.upgrade_pipelines.delay(
-            urls=urls,
-            force=force,
-            girder_job_title="Upgrade Pipelines",
-            girder_client_token=str(token["_id"]),
+        tasks.upgrade_pipelines.apply_async(
+            queue='pipelines',
+            kwargs=dict(
+                urls=urls,
+                force=force,
+                girder_job_title="Upgrade Pipelines",
+                girder_client_token=str(token["_id"]),
+            ),
         )
 
     @access.admin