芹菜:以编程方式将任务排队到特定队列



当我这样做时sometask.async_apply(args=['args1','args2'], kwargs={'queue': 'dev'})没有任何东西最终出现在队列'dev'上。我想知道我是否在某处错过了一步?我已经创建了队列"dev",当我检查 rabbitmq 管理时,它显示在队列下。

你应该做这样的事情:

sometask.apply_async(args = ['args1','args2'], queue = 'dev')

最新更新