我很难找到一种方法来执行以下操作:
我有一个“复杂”的芹菜工作流程:
r = chain(
one.si(),
chord(
header=group(
two.si(),
three.si()
),
body=four.si()
)
).delay()
r.revoke(terminate=True)只停止第一个任务(“一个”),忽略其他任务。在
我需要在任何任务运行时撤消所有任务。在
例如:
当任务“2”正在运行时,我需要停止工作流并撤销并行任务“2”和“3”以及chord(任务“4”)的回调。在
在芹菜里有没有办法做到这一点?在
目前没有回答
相关问题 更多 >
编程相关推荐