Wie führe ich parallele Aufgaben mit Sellerie aus?

Question

Ich verwende Sellerie, um einige Aufgaben zu erledigen, die lange dauern. Dort ist eine erste Aufgabe, die abgeschlossen werden muss, bevor zwei Teilaufgaben ausgeführt werden können. Die von mir erstellten Tasks sind Dateisystemoperationen und geben kein Ergebnis zurück.

Ich möchte die Teilaufgaben zur gleichen Zeit ausführen, aber wenn ich eine Gruppe für diese Aufgaben verwenden, laufen sie sequentiell und nicht parallel.

Ich habe versucht:

g = group([secondary_task(), secondary_tasks2()]) 
chain(initial_task(),g) 

ich auch habe versucht, die Gruppe, die direkt in der ersten Aufgabe ausgeführt wird, aber das scheint nicht zu funktionieren.

Was versuche ich mit Sellerie zu erreichen?

First Task 
/    \ 
Second Task  Third Task 

Nicht:

First Task 
    | 
Second Task 
    | 
Third Task 

Answer 1

Die Kette ist auf jeden Fall der richtige Ansatz.

Ich würde dies erwarten zu arbeiten: Kette (initial_task.s(), g)()

Haben Sie mehr als ein Sellerie Arbeiter laufen haben, um mehr als eine Aufgabe gleichzeitig laufen zu lassen?