芹菜任務鏈取消？

Question

我發現芹菜支持任務鏈：http://celery.readthedocs.org/en/latest/userguide/canvas.html#chains。

問題是：如何在任務中阻止鏈的執行？

例如，我們得到了一個N​​個項目（N> 2）的鏈。在第二項任務中，我們意識到我們不需要執行所有其餘的任務。該怎麼辦？

Answer 1

在較新版本的芹菜（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)