diff --git a/swh/scheduler/celery_backend/config.py b/swh/scheduler/celery_backend/config.py --- a/swh/scheduler/celery_backend/config.py +++ b/swh/scheduler/celery_backend/config.py @@ -227,8 +227,6 @@ worker_disable_rate_limits=True, # Task routing task_routes=route_for_task, - # Task queues this worker will consume from - task_queues=CELERY_QUEUES, # Allow pool restarts from remote worker_pool_restarts=True, # Do not prefetch tasks @@ -245,8 +243,9 @@ {k: v for (k, (_, v)) in DEFAULT_CONFIG.items()}, config or {}) - config['task_queues'] = [Queue(queue, Exchange(queue), routing_key=queue) - for queue in config.get('task_queues', ())] + config['task_queues'] = CELERY_QUEUES + [ + Queue(queue, Exchange(queue), routing_key=queue) + for queue in config.get('task_queues', ())] logger.debug('Creating a Celery app with %s', config) # Instantiate the Celery app