fix: allow to add default parameters

eduNEXT · Sep 11, 2024 · d6d9be0 · d6d9be0
1 parent 974ab08
commit d6d9be0
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/tutorcelery/patches/k8s-override b/tutorcelery/patches/k8s-override
@@ -1,5 +1,6 @@
 {% if CELERY_MULTIQUEUE_ENABLED %}
 {% for service in ["lms", "cms"] %}
+{% set config = iter_celery_workers_config().get(service).get("default") %}
 ---
 apiVersion: apps/v1
 kind: Deployment
@@ -18,7 +19,8 @@ spec:
             - "--hostname=edx.{{service}}.core.default.%%h"
             - "--max-tasks-per-child=100"
             - "--queues=edx.{{service}}.core.default"
-            - "--pool=threads"
-            - "--concurrency=16"
+            {% for setting, value in config.get("extra_params", {}).items() %}
+            - "--{{setting}}={{value}}"
+            {% endfor %}
 {% endfor %}
 {% endif %}