Apache Airflow调度器报错:请检查core段executor配置值CeleryExecutor
Airflow Celery Executor配置报错解决方案
- 先确认
core段executor配置的取值正确性:Airflow中Celery执行器的正确配置值是CeleryExecutor(驼峰命名、无空格),如果你写成了Celery Executor(带空格),会导致Airflow无法识别该执行器类型,触发报错。 - 检查Airflow实际读取的配置文件路径:运行以下命令查看配置来源
找到airflow config list --show-origincore.executor对应的文件路径,确保你修改的是这个路径下的airflow.cfg。 - 修正配置后重启Airflow调度器:
- 若用systemd管理服务:
sudo systemctl restart airflow-scheduler sudo systemctl restart airflow-worker - 若直接命令行启动,先终止当前调度器进程,再重新启动:
airflow scheduler
- 若用systemd管理服务:
- 确保Celery相关依赖已安装:
pip install 'apache-airflow[celery]' - 验证消息队列(如Redis或RabbitMQ)已正确配置并处于运行状态,Celery Executor依赖消息队列实现任务分发。
内容的提问来源于stack exchange,提问作者Kumar Reddy
相关产品推荐
相关产品推荐

