芹菜父母任务的生命周期是什么？

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。