如何将一系列任务路由到芹菜中的特定队列？

Question

当我将任务路由到特定队列时，它会工作：

task.apply_async(queue='beetroot')

但如果我创造了一个链子：

chain = task | task

然后我写

chain.apply_async(queue='beetroot')

它似乎忽略了queue关键字并将其分配给默认的“芹菜”队列。

如果celery支持链式路由-所有任务都在同一队列中按顺序执行，那就太好了。

Answer 1

我是这样做的：

subtask = task.s(*myargs, **mykwargs).set(queue=myqueue)
mychain = celery.chain(subtask, subtask2, ...)
mychain.apply_async()