假设有以下任务:
@app.task
def task1(v1, v2):
return "val3"
@app.task
def task2(v1, v2, v3):
return "val4"
@app.task
def task3(v1, v2, v3):
return "val4"
考虑以下工作流程:
workflow = chain(
task1.s(),
group(
task2.s(),
task3.s()
)
)
result = workflow.delay("val1", "val2")
我该如何让celery将原始参数val1
和val2
传递给组内的task2
和task3
。 只有task1
的结果被传递。