Как выбрать очередь результатов для задачи сельдерея?

Question

Вот мой сельдерей конфигурации:

BROKER_TRANSPORT='amqp', 
CELERY_RESULT_BACKEND='rpc://', 

Я посылаю задачу выполнить следующим образом:

result = my_function.apply_async(('arguments here',), queue='queue_123') 

Сельдерей работает как и ожидалось, я вижу эти задачи в «queue_123».

Теперь мне нужно получить все результаты выполнения в очередь «my_result_queue». Как мне это сделать?

Сельдерей теперь создает новую очередь с именем «19b7013a-a077-3d2a-b60a-d57c51d5d30c» и вставляет в нее результаты. Мне нужно исправить это поведение и вставить результаты в очередь с указанным именем.

мне нужно что-то вроде этого:

result = my_function.apply_async(('arguments here',), queue='queue_123', results_queue='my_result_queue') 

Answer 1

@app.task(reply_to='result_queue)