获取任务组中第一个任务的结果（芹菜）

Question

如何获取组内第一个任务的结果？

我正在使用这种方式 -

res = chain.delay()
first_task = res.parent.parent.parent.parent.parent.collect()

但是超级丑，有没有更漂亮的方法？

Answer 1

虽然没有那么优雅，但您可以使用 while 循环进行泛化：

def first_result(res):
    r = res
    while r.parent:
        r = r.parent
    return r.result()

Get result of first task in group of tasks (celery)