Hủy chuỗi nhiệm vụ cần thiết?

Question

Tôi thấy cần tây hỗ trợ chuỗi nhiệm vụ: http://celery.readthedocs.org/en/latest/userguide/canvas.html#chains.

Câu hỏi là: cách tôi có thể ngừng thực hiện chuỗi trong một công việc?

Ví dụ: chúng tôi có một chuỗi các mục N (N> 2). Và trong nhiệm vụ thứ hai, chúng tôi nhận ra rằng chúng tôi không cần tất cả các nhiệm vụ còn lại để thực thi. Phải làm gì?

Answer 1

Trong phiên bản mới hơn của cần tây (3.1.6), bạn có thể thu hồi toàn bộ chuỗi bằng cách đơn giản là đi bộ chuỗi và thu hồi từng mục.

# 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)