From ed4d761741a17e619d5f4ecf79b3923d053955c9 Mon Sep 17 00:00:00 2001
From: Egor fureunoir Gorbunov <contact@fureunoir.com>
Date: Wed, 2 Jul 2025 01:32:05 +0300
Subject: [PATCH] Features: 1) Add task routing configuration for
 'core.tasks.update_products_task' to use 'stock_updater' queue;

Fixes: 1) Remove deprecated `worker_autoscale` setting;

Extra: 1) Minor cleanup in Celery configuration; 2) Removed unused settings for `worker_prefetch_multiplier`, `worker_max_tasks_per_child`, `task_soft_time_limit`, and `task_time_limit`.
---
 evibes/celery.py | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/evibes/celery.py b/evibes/celery.py
index d0479561..489ae785 100644
--- a/evibes/celery.py
+++ b/evibes/celery.py
@@ -14,7 +14,6 @@ app.conf.update(
     worker_hijack_root_logger=False,
     worker_log_format="[%(asctime)s: %(levelname)s/%(processName)s] %(name)s: %(message)s",
     worker_task_log_format="[%(asctime)s: %(levelname)s/%(processName)s] %(name)s: %(message)s",
-    worker_autoscale=(10, 3),
     broker_connection_retry_on_startup=True,
     timezone=TIME_ZONE,
     task_serializer="json",
@@ -27,12 +26,12 @@ app.conf.update(
     },
     task_acks_late=True,
     task_reject_on_worker_lost=True,
-    worker_prefetch_multiplier=1,
-    worker_max_tasks_per_child=100,
-    task_soft_time_limit=10800,
-    task_time_limit=21600,
 )
 
+app.conf.task_routes = {
+    'core.tasks.update_products_task': {'queue': 'stock_updater'},
+}
+
 app.config_from_object("django.conf:settings", namespace="CELERY")
 
 app.autodiscover_tasks()