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
相关产品推荐
相关产品推荐

