fix: Celery queue 3 name

EBISPOT · Apr 23, 2024 · 5eff2eb · 5eff2eb
1 parent d5b3ebb
commit 5eff2eb
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/k8chart/values.yaml b/k8chart/values.yaml
@@ -18,7 +18,7 @@ image:
     celeryPwd: "password"
     celeryQueue1: "preval"
     celeryQueue2: "postval"
-    celeryQueue3: "metadata-yml-update-sandbox"
+    celeryQueue3: "metadata-yml-update"
     storagePath: "./data"
     validateSSH: true
     computeFarmLogin: ""
@@ -78,7 +78,7 @@ service:
 
 worker:
   name: gwas-ss-worker
-  celeryCmd: '["celery", "-A", "sumstats_service.app.celery", "worker", "--loglevel=INFO", "--queues=preval,postval,metadata-yml-update-sandbox"]'
+  celeryCmd: '["celery", "-A", "sumstats_service.app.celery", "worker", "--loglevel=INFO", "--queues=preval,postval,metadata-yml-update"]'
   celeryCmdPostOnly:  '["celery", "-A", "sumstats_service.app.celery", "worker", "--loglevel=INFO", "--queues=postval"]'
   replicaCount: 1
 

diff --git a/sumstats_service/app.py b/sumstats_service/app.py
@@ -298,7 +298,7 @@ def get_dir_contents(unique_id):
 # --- Celery tasks --- #
 # postval --> app side worker queue
 # preval --> compute cluster side worker queue
-# metadata-yml-update-sandbox --> dynamic metadata update queue
+# metadata-yml-update --> dynamic metadata update queue
 
 
 @celery.task(queue=config.CELERY_QUEUE2, options={"queue": config.CELERY_QUEUE2})

diff --git a/tests/conftest.py b/tests/conftest.py
@@ -14,7 +14,7 @@ def celery_config():
                 port=os.environ['QUEUE_PORT']
                 ),
             'result_backend': 'rpc://',
-            'queues':('preval', 'postval', 'metadata-yml-update-sandbox'),
+            'queues':('preval', 'postval', 'metadata-yml-update'),
             'task_always_eager': True
            }