You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Celery Chord回调提前执行问题求助:父回调在子任务回调完成前触发

Celery Chord回调提前执行问题求助:父回调在子任务回调完成前触发

各位大佬好,我最近在做一个Celery嵌套Chord的工作流,遇到了个头疼的问题:parent_task_callback居然在所有的sub_parent_task_callback执行完成之前就被触发了,完全打乱了预期的执行顺序。

我已经排查过常见的问题点:所有任务都没有单独设置ignore_result=False,全局配置里也没开这个选项,按道理Chord应该能正确追踪子任务的执行状态才对。

我的核心代码大概是这样的:

@app.task
def sub_parent_task():
    chord(child_tasks_list)(sub_parent_task_callback.si())

@app.task
def parent_task():
    chord(sub_parent_tasks_list)(parent_task_callback.si())

有没有大佬能帮我看看,我到底忽略了什么细节?是不是嵌套Chord的用法本身有什么需要注意的地方?

内容来源于stack exchange

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.04.07 09:30:27