Celery Chain中on_success处理器与后续任务的执行顺序疑问

我用Celery的Chain组件构建了如下任务链：

chain(
    first_task.s(),
    second_task.s(),
    third_task.s(),
).apply_async()

这些任务都实现了on_success和on_failure处理器函数，用来向另一系统发送执行结果通知。该系统对通知消息的顺序有依赖，我原本以为链中的任务（包括on_success和on_failure处理器）会按顺序执行，但实际发现如果第二个任务执行速度极快，它的on_success消息可能会比第一个任务的on_success消息先发送出去。

核心疑问 #

链中的下一个任务是否会在前置任务的on_success处理器执行前被调度？

查看Celery v5.5.2版本的trace.py代码后，答案是肯定的，代码执行流程如下：

• 第453行：执行当前任务（比如第一个任务）
• 第515行：调度链中的下一个任务（比如第二个任务）
• 第529行：执行当前任务的on_success处理器

这就解释了通知顺序混乱的原因：第二个任务在第一个任务的on_success处理器执行前就已被调度启动，若它执行速度足够快，其on_success处理器会先触发，导致通知消息顺序颠倒。

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