celery settings

leftmove · Jun 27, 2024 · 59b90d5 · 59b90d5
1 parent 880884d
commit 59b90d5
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/backend/routers/worker.py b/backend/routers/worker.py
@@ -21,10 +21,14 @@
 
 production_environment = True if ENVIRONMENT == "production" else False
 run_telemetry = True if TELEMETRY else False
-config = {"worker_concurrency": WORKERS, "broker_connection_retry_on_startup": True}
+
+class Config:
+    worker_concurrency = WORKERS
+    conccurrency = 4
+    broker_connection_retry_on_startup = True
 
 queue = Celery("worker", broker=BROKER)
-queue.config_from_object(config)
+queue.config_from_object(Config)
 
 
 @signals.celeryd_init.connect