Airflow任务处于排队状态却始终不运行，该如何处理？
2026-8-16
Airflow任务排队不运行？排查与解决指南（适配MWAA本地运行器+Airflow2.2.2）
先划重点：排队不运行≠代码错误
任务卡在排队状态，绝大多数情况是资源不足、调度/执行组件异常、配置不合理导致的，代码错误一般会直接触发任务失败（日志里会明确报错），不会一直卡在排队阶段。
分步排查+解决方法
1. 先查Celery执行器的状态（MWAA本地默认用这个）
- 看worker容器是否存活：在本地终端执行
docker-compose ps，检查worker容器状态是否为Up；如果是Exited或Restarting，直接重启容器：docker-compose restart worker - 调大worker并发数：默认worker并发可能不足，打开Airflow UI的Admin > Configuration，找到
celery worker_concurrency，把值从默认的2往上调整（比如4）；或者修改docker-compose.yml里的worker服务配置后重启 - 检查Docker资源配额：如果本地Docker分配的CPU/内存太少，worker无法承载任务，去Docker设置里调高资源上限（比如分配4G内存、2核CPU）
2. 验证调度器是否正常工作
调度器是触发任务的核心，异常会导致任务无法被拾取：
- 查调度器容器状态：
docker-compose ps查看scheduler容器是否正常运行，有没有频繁重启记录 - 查看调度器日志：
docker-compose logs scheduler，搜索no tasks to schedule或task instance not picked up，排查调度逻辑的异常提示 - 检查调度心跳配置：在Airflow UI中找到
scheduler_heartbeat_sec，默认是5秒，若设置过大会导致任务触发延迟，改回默认值即可
3. 检查任务自身的配置坑
部分任务配置会导致无法被调度：
- 队列不匹配：如果任务指定了自定义队列，但worker未监听该队列，任务会一直排队。要么将任务的
queue参数改为default，要么在Admin > Queues中给worker添加对应队列的监听 - 时间配置错误：
start_date设为未来时间，或schedule_interval配置无效（比如设为None但未配置trigger_rule），任务会一直处于待调度状态而非排队，需修正时间参数 - 上游任务阻塞：下游任务会等待上游完成才会运行，去Airflow UI的Graph View查看上游任务是否失败或同样卡在排队，优先解决上游问题
4. 最后排查代码（概率较低）
如果以上都没问题，再检查代码：
- 有无阻塞逻辑：任务的
execute方法中如果存在无限循环、长时间等待外部资源且未设置超时，可能导致任务卡在运行状态，但一般不会一直排队，仍需排查 - 关闭catchup：如果DAG的
catchup=True且历史任务堆积较多，调度器会优先处理历史任务，新任务会排队，添加catchup=False即可 - 查看任务日志：哪怕任务未运行，部分初始化阶段的报错会写入日志，点击任务的Log按钮查看是否有异常
5. MWAA本地环境专属排查
针对AWS MWAA本地运行器的特殊情况：
- 重置环境：若环境配置混乱，直接执行
./mwaa-local-env reset重置，然后重新启动 - 检查依赖包：
requirements.txt中的包若与Airflow2.2.2、Python3.7不兼容，可能导致worker崩溃。先注释掉非必要的包，重启worker尝试 - 本地存储问题：检查DAG文件或日志的存储目录是否有权限问题，磁盘空间是否充足；若磁盘满了，调度器无法读取DAG，任务也无法运行
内容的提问来源于stack exchange，提问作者masaaa015
相关产品推荐
相关产品推荐
