按顺序在芹菜中运行多个链条

Question

我正在尝试使用芹菜链来检查文件，然后将它们记录为选中。

目前我的代码看起来像这样

for file in list_of_files:
task_chain = chain(task1.s(file), task.si(file))
task_chain.apply_async()

但是，当我运行代码时，工作人员在执行"task2"之前执行所有"task1"。有没有办法告诉工作人员在任务 1 之后立即运行任务 2？

非常感谢任何帮助。

Answer 1

您是否尝试过芹菜文档中演示的回调：https://docs.celeryproject.org/en/latest/userguide/canvas.html#callbacks

所以你可以试试：

task_chain = chain(task1.s(file), task.si(file))
task_chain.apply_async(link=task2.si())