芹菜父母任務的生命週期是什麼？

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' 

它只是計劃組任務，然後繼續下一步。它沒有等待子任務完成。

但是，如果你想要一個任務等待另一個任務，那麼你需要can use chain。