Celery任务链的取消？

Question

我发现celery支持任务链: http://celery.readthedocs.org/en/latest/userguide/canvas.html#chains.

问题是: 如何在任务中停止链的执行？

例如，我们有一个由N个项目组成的链(N > 2)。在第二个任务中，我们意识到不需要执行所有剩余的任务。该怎么做？

- Nikita Hismatov

---

当您想要停止任务时，在任务中引发异常怎么样？ - RickyA

抛出异常对我没有起作用。我在这里发布了详细的解释：https://dev59.com/LGQm5IYBdhLWcg3wowMF - Salami

Answer 1

在较新版本的Celery（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)

- Andrew Walker