Cicer'in ana görevlerinin yaşam döngüsü nedir?

Question

Bir üst görevin yaşam döngüsü nedir? Bir ebeveyn görevi dahilinde bu grup işlevini çağırırsanız tüm alt görevleri kendisini sonlandırmadan önce sona kadar

group(add.s(i, i) for i in xrange(100))() 

, ebeveyn bekler?

Answer 1

Bir üst görev oluşturdum ve bundan grup denir. add'da bir gecikme ekledim, böylece bunu yürütmek biraz zaman alacak.

@app.task() 
def add(x, y): 
    time.sleep(10) 
    return x + y 


@app.task() 
def parent(): 
    print('start') 
    group(add.s(i, i) for i in xrange(100))() 
    print('stop') 

Ana görevi çağırdım.

In [3]: r = parent.delay() 

In [4]: r.state 
Out[4]: 'SUCCESS' 

Sadece grup görevini planladı ve sonraki adım için devam etti. Alt görevlerin tamamlanması için , beklemedi.

Ancak, bir görevin başka bir görev için beklemesini istiyorsanız, can use chain.