通过send_task链接芹菜中的两个远程任务

在芹菜中,我想将远程工作者的两个任务链接在一起.有人可以告诉我如何在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()
点赞