9
我发现芹菜支持任务链:http://celery.readthedocs.org/en/latest/userguide/canvas.html#chains。芹菜任务链取消?
问题是:如何在任务中阻止链的执行?
例如,我们得到了一个N个项目(N> 2)的链。在第二项任务中,我们意识到我们不需要执行所有其余的任务。该怎么办?
我发现芹菜支持任务链:http://celery.readthedocs.org/en/latest/userguide/canvas.html#chains。芹菜任务链取消?
问题是:如何在任务中阻止链的执行?
例如,我们得到了一个N个项目(N> 2)的链。在第二项任务中,我们意识到我们不需要执行所有其余的任务。该怎么办?
在较新版本的芹菜(3.1.6)中,您可以通过简单地走链和依次撤销每个项目来撤消整个链。
# Build a chain for results
from tasks import addd
from celery import chain
def revoke_chain(result):
while result:
result.revoke()
result = result.parent
# independent tasks (with immutable signatures)
c = chain(*tuple(add.si(i,i) for i in xrange(50)))
h = c()
# some time later ...
revoke_chain(h)
# dependant task
c = add.s(1,1) | add.s(2) | add.s(3)
h = c()
# some time later ...
revoke_chain(h)
如果在任务中想要停止时引发异常,那该怎么办? – RickyA
听起来不错:)我会尝试 –
它是否工作?... – RickyA