Airflow UI不显示自定义DAG dags list命令无法查询到该DAG
问题根因
你的DAG文件存在基础拼写错误,导致Python解析文件时直接抛出导入异常,DAG加载流程中断,因此不会出现在UI和DAG列表中。
错误出现在导入语句部分,你将airflow错拼为airlow(字母f误写为l),错误代码片段:
from airlow import DAG from airlow.operators.bash import BashOperator
修正后的正确导入语句:
from airflow import DAG from airflow.operators.bash import BashOperator
修复及验证流程
- 修正上述拼写错误后保存DAG文件
- 执行导入错误检查命令,确认文件无解析异常:
命令返回结果中如果没有airflow dags list-import-errorsparallel_dag相关的报错,说明DAG文件已经可以被Airflow正常识别 - 执行DAG列表查询命令,确认自定义DAG已被收录:
airflow dags list - 等待Airflow Scheduler和Webserver完成DAG目录扫描(默认扫描间隔为30秒,可通过
airflow.cfg中dag_dir_list_interval参数调整),刷新UI页面即可在DAG列表中看到对应条目。
补充排查项:如果修正拼写后DAG仍无法加载,依次确认以下配置:
- DAG文件后缀为
.py- Airflow运行进程所属用户对该DAG文件有可读权限
- DAG文件没有存放在dags目录下的隐藏子目录(目录名以
.开头的文件夹默认会被扫描器忽略)
内容的提问来源于stack exchange,提问作者Ruslan Pylypyuk
相关产品推荐
相关产品推荐

