在芹菜中,我想将远程工作者的两个任务链接在一起.有人可以告诉我如何在send_task中指定它吗?或者还有其他任何方式来调用远程任务吗?
BR
最佳答案 最简单的方法是使用’签名’功能:
from celery import signature
chain = signature(
'app_name.task_1',
kwargs={..},
queue='this_queue'
)
chain |= signature(
'app_name2.task2',
kwargs={..},
queue='another_queue'
)
chain.apply_async()