Setup: celery 4.1, broker: RabbitMQ 3.6.5, backend Redis.
From the Documentation, there are several ways for routing:
Option 1 Automatic Routing:
task_routes = {
'import_feed_task': {
'queue': 'feed_tasks',
'routing_key': 'feed_tasks',
},
}
Option 2 Special Routing:
task_queues = [
Queue('feed_tasks', Exchange('feed_tasks'), routing_key='feed_tasks',
queue_arguments={'x-max-priority': 10},
]
I want to use the priority (queue_arguments={'x-max-priority': 10}
) within the first option. Is it possible/supported?