Was ist der Lebenszyklus von Selleries Elternaufgaben?

Question

Was ist der Lebenszyklus einer übergeordneten Aufgabe?

Wenn ich diese Gruppenfunktion in einer übergeordneten Aufgabe aufruft, wartet das übergeordnete Element, bis alle Unteraufgaben beendet sind, bevor es sich selbst beendet?

Answer 1

Ich erstellte eine übergeordnete Aufgabe und rief Gruppe von ihm. Ich habe gerade eine Verzögerung in add hinzugefügt, so dass es eine Weile dauern wird, um es auszuführen.

@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') 

Ich rief Eltern-Task.

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

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

Es wurde nur Gruppenaufgabe geplant und dann für den nächsten Schritt fortgesetzt. Es wartete nicht für die Teilaufgaben abzuschließen.

Wenn Sie jedoch möchten, dass eine Aufgabe auf eine andere Aufgabe wartet, geben Sie can use chain ein.