セロリの親タスクのライフサイクルはどのくらいですか？

Question

親タスクのライフサイクルはどのくらいですか？

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

親タスク内でこのグループ関数を呼び出すと、すべてのサブタスクが終了して終了するまで親が終了しますか？

Answer 1

私は親タスクを作成し、そこからグループを呼び出しました。私はちょうどaddに遅れを加えましたので、それを実行するのに時間がかかります。

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

私は親タスクと呼ばれました。

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

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

これはちょうどグループタスクをスケジュールし、次のステップに進みました。 は、サブタスクが完了するまで、を待たなかった。

ただし、1つのタスクが別のタスクを待つ場合は、can use chainです。