Airflow Web UI中DAG不显示问题求助（Docker部署场景）

尝试创建一个简单的Airflow DAG，代码如下：

from airflow.models import BaseOperator, Param
from airflow.models.dag import dag
from airflow.utils.dates import days_ago

default_args = {
    'owner': 'airflow',
    'start_date': days_ago(1),
}


@dag(dag_id='my_dag', default_args=default_args, schedule_interval=None)
def my_dag(param: str = Param(default='option1', choices=['option1', 'option2', 'option3'])):

    print_value_task = BaseOperator(
        task_id='print_value',
        python_callable=lambda: print(f'The value of param3 is: {param}')
    )

    print_value_task

当代码存在错误时，Airflow Web UI会显示错误提示；但代码无错误时，该DAG却未在Web UI中显示，无法手动触发。使用Docker镜像部署Airflow，将DAG文件放在主机与容器挂载的目录中，请问哪里操作有误？

1. DAG未完成实例化 #

使用@dag装饰器定义DAG函数后，必须调用该函数才能生成可被Airflow识别的DAG对象。在你的代码末尾添加一行：

my_dag()

这是Airflow 2.x版本使用装饰器定义DAG的强制步骤，未调用函数的话，Airflow无法注册这个DAG。

2. 错误使用BaseOperator #

BaseOperator是所有Airflow操作符的基类，不适合直接用来定义任务，应该使用专门执行Python逻辑的PythonOperator。修改任务定义部分：

from airflow.operators.python import PythonOperator

# 保留原有导入与default_args定义

@dag(dag_id='my_dag', default_args=default_args, schedule_interval=None)
def my_dag(param: str = Param(default='option1', choices=['option1', 'option2', 'option3'])):
    print_value_task = PythonOperator(
        task_id='print_value',
        python_callable=lambda param_val: print(f'The value of param is: {param_val}'),
        op_kwargs={'param_val': param}
    )
    return print_value_task

my_dag()

直接使用BaseOperator会因缺少执行逻辑导致任务无法被正确解析。

3. Docker挂载与权限检查 #

• 确认主机DAG目录挂载到了容器内的Airflow默认DAG路径（通常是/opt/airflow/dags），可以进入容器验证：

  docker exec -it <airflow-webserver容器名> ls /opt/airflow/dags
  

  若容器内未看到DAG文件，检查挂载命令是否正确，示例正确挂载命令：

  -v /主机本地DAG目录路径:/opt/airflow/dags
  

• 调整主机DAG目录权限，确保容器内的airflow用户有读取权限：

  chmod -R 755 /主机本地DAG目录路径
  

4. 调度器状态验证 #

Airflow依赖调度器扫描DAG目录并加载DAG，确保调度器容器正常运行，可查看调度器日志确认DAG加载情况：

docker logs <airflow-scheduler容器名>

若日志中无DAG加载相关记录，检查调度器容器是否正常启动。

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