Celery Chain问题：外层链最终任务始终未执行的排查求助

我来帮你搞定这个Celery任务链的问题！你遇到的核心问题是外层链里的final_sum.s()没有接收前一个group任务的返回结果作为参数，导致Celery认为这个任务没有触发条件，所以即使前面所有步骤都成功了，它也不会被调用。

问题根源拆解 #

先看你代码里的关键部分：

chain(group([the_big_task1, the_big_task2]), final_sum.s())

Celery的chain是按顺序执行任务的，每一个后续任务都会自动接收前一个任务的返回值作为输入参数。但如果你的final_sum函数没有声明要接收参数，或者前一个任务的结果没正确传递过来，就会出现任务“躺平”不执行的情况。

另外你的代码里还有个小笔误：第一个循环里你定义了tasks1，但写的是tasks.append(add.s(i))，这会导致tasks1为空，不过这应该是你敲代码时的疏忽。

修正后的完整代码示例 #

我给你调整了代码，确保参数能正确传递，同时补上了必要的执行调用：

from celery import chain, group, task

# 先模拟你的任务定义（根据实际情况调整）
@task
def get_one():
    return 1

@task
def add(num):
    return num + 1

@task
def sum_fun(values):
    # 处理group返回的结果列表，求和
    return sum(values)

@task
def final_sum(results):
    # 接收两个sum_fun的结果，比如[14,24]，再做最终求和
    return sum(results)

def function_task():
    tasks1 = []
    for i in xrange(10, 13):
        tasks1.append(add.s(i))  # 修正笔误：用tasks1而不是tasks
    the_big_task1 = chain(get_one.s(), group(tasks1), sum_fun.s())
    
    tasks2 = []
    for i in xrange(20, 23):
        tasks2.append(add.s(i))
    the_big_task2 = chain(get_one.s(), group(tasks2), sum_fun.s())
    
    # 构建最终链：group执行完会返回两个sum_fun的结果列表，自动传给final_sum
    final_task_chain = chain(group([the_big_task1, the_big_task2]), final_sum.s())
    # 一定要调用delay()或者apply_async()来启动整个链的执行！
    final_task_chain.delay()

关键要点提醒 #

• group([the_big_task1, the_big_task2])执行完成后，会返回一个包含两个sum_fun执行结果的列表（比如[14,24]）
• final_sum.s()会自动接收这个列表作为参数，只要你的final_sum函数定义了对应的参数，Celery就会正常触发它的执行
• 最后别忘了调用delay()或者apply_async()，不然整个任务链只会被定义，不会实际运行

内容的提问来源于stack exchange，提问作者Biddappa Muthappa