disable old renku version so this can be tested

SwissDataScienceCenter · Jan 25, 2022 · 52e7bd9 · 52e7bd9
1 parent 8dda5ca
commit 52e7bd9
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 11 deletions.
diff --git a/helm-chart/renku-core/values.yaml b/helm-chart/renku-core/values.yaml
@@ -106,12 +106,12 @@ versions:
       repository: renku/renku-core
       tag: "v1.0.1"
       pullPolicy: IfNotPresent
-  v8:
-    name: v8
-    prefix: "8"
-    nameOverride: ""
-    fullnameOverride: ""
-    image:
-      repository: renku/renku-core
-      tag: "v0.16.2"
-      pullPolicy: IfNotPresent
+  # v8:
+  #   name: v8
+  #   prefix: "8"
+  #   nameOverride: ""
+  #   fullnameOverride: ""
+  #   image:
+  #     repository: renku/renku-core
+  #     tag: "v0.16.2"
+  #     pullPolicy: IfNotPresent
diff --git a/renku/service/controllers/api/mixins.py b/renku/service/controllers/api/mixins.py
@@ -29,6 +29,7 @@
 from renku.core.management import RENKU_HOME
 from renku.core.metadata.repository import Repository
 from renku.core.utils.contexts import click_context
+from renku.service.cache.config import WALRUS_NAMESPACE
 from renku.service.cache.models.job import Job
 from renku.service.cache.models.project import Project
 from renku.service.cache.models.user import User
@@ -145,7 +146,7 @@ def execute_op(self):
 
             job = self.cache.make_job(self.user, job_data={"ctrl_context": {**self.context, **ctrl_cls}})
 
-            with enqueue_retry(f"delayed.ctrl.{ctrl_cls['renku_ctrl']}") as queue:
+            with enqueue_retry(f"{WALRUS_NAMESPACE}.delayed.ctrl.{ctrl_cls['renku_ctrl']}") as queue:
                 queue.enqueue(delayed_ctrl_job, self.context, self.user_data, job.job_id, **ctrl_cls)
 
             return job

diff --git a/renku/service/jobs/queues.py b/renku/service/jobs/queues.py
@@ -70,7 +70,6 @@ def describe():
     @staticmethod
     def get(name):
         """Get specific queue object."""
-        name = f"{WALRUS_NAMESPACE}.{name}"
         return Queue(
             name, connection=WorkerQueues.connection, default_timeout=int(os.getenv("WORKER_DEFAULT_JOBS_TIMEOUT", 600))
         )