D1190.diff
No OneTemporary
Actions

Size

986 B

Subscribers

None

D1190.diff
View Options

	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