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()