celery - 如果指定了队列，则无法运行 celery 子任务

Question

我正在使用 mongodb 作为后端和代理运行 celery 3.0.19。我想在子任务中使用队列，但它不起作用。以下是如何从示例add任务中重现问题。

使用命令启动 celery worker

celery -A tasks worker --loglevel=info --queue=foo

然后创建一个永远不会像那样完成的任务

from tasks import add
sub_task = add.s(queue="foo")
sub_task_async_result = sub_task.apply_async((2,2))

请注意以下任务将正常执行。

async_result = add.apply_async((2,2), queue="foo")

我做错了什么？

谢谢！