airflow not recognize local directory ModuleNotFoundError: No module named

airflow not recognize local directory ModuleNotFoundError: No module named

我的项目结构如下：

my_project
 -dags
 -config

但是在气流仪表板上我看到一个错误 Broken DAG 指向这一行：from config.setup_configs import somemethod

并产生这个错误：

Broken DAG: [/usr/local/airflow/dags/airflow_foo.py] No module named 'config'

虽然目录存在

根据 documentation Airflow 默认有三个目录到路径

  • AIRFLOW_HOME/dags
  • AIRFLOW_HOME/config
  • AIRFLOW_HOME/plugins

必须将任何其他路径添加到系统路径，如 airflow module management

中所述

为了简单起见，我将我的模块mymodule.py添加到AIRFLOW_HOME/plugins，我可以成功导入它们。

from mymodule import my_method

因此，在您的情况下，如果您将 configurations 重命名为 plugins 并将导入语句更新为 DAG，

from setup_configs import somemethod

应该可以。