如何爲芹菜任務選擇結果隊列？

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)