我想在链中使用一个组(或块),例如:
chain(getRange.s(3), GROUP() , xsum.s() )
Run Code Online (Sandbox Code Playgroud)
GROUP()一组double()任务在哪里,即group(double(0),double(1),double(2)).在如何链接一个将列表返回到组中的Celery任务中发布了类似的问题?但是没有解释如何将组中的输出传递给链中的下一个任务.
@task
def getRange(x):
return range(x)
@task
def double(nr):
return nr*2
@task
def xsum(list):
return sum(list)
Run Code Online (Sandbox Code Playgroud)