2.2.2.1 CeleryExecutor 架构

文档摘要

2.2.2.1 CeleryExecutor 架构 2.2.2.1 CeleryExecutor 架构：当任务“卡在 pending”——一次生产环境中的 Celery 任务状态漂移溯源与原子级修复凌晨两点十七分，告警钉钉弹窗第三次亮起：“Airflow DAG 连续 3 小时未完成，最新运行状态：，但下游 7 个 task 实际无日志、无心跳、无进程。” 运维同事甩来一张截图：Celery Flower 界面里，那几个 task 的状态赫然写着 ——可它们明明已被调度器（Scheduler）发往队列，Worker 也确认消费了消息，却像被施了定身咒，既不执行，也不失败，更不重试。这不是偶发抖动。