我对 Celery 很陌生,并计划用它来安排一些工作。其中一种情况如下。
TASK_NM | DEPENDENCY
T1
T2 | T1
T3 | T1
T4
T5 | T3 and T4
Run Code Online (Sandbox Code Playgroud)
从上面的案例来看,
我必须并行执行 T1 和 T4
T1成功完成后,并行执行T2和T3
成功完成T3和T4后,执行T5。
如果任何任务中途失败,则不执行相关作业。
我们如何使用 Celery 实现这一目标?
提前致谢!!!