如何更改 Airflow web ui 的 dag bag 文件夹?

avi*_*jay 6 python python-3.x airflow airflow-scheduler

气流调度程序正在根据气流.cfg 文件中的设置从正确的文件夹中提取 dag。但是,Airflow ui 网络服务器从错误的文件夹中选择了 dag。我通过查看运行气流网络服务器的终端的标准输出来意识到这一点:[2018-10-08 14:26:48,519] [15535] {models.py:167} INFO - Filling up the DagBag from /home/aviral/airflow/dags

注意,我的airflow.cfg 文件有:

# The folder where your airflow pipelines live, most likely a
# subfolder in a code repository
# This path must be absolute
dags_folder = /home/aviral/dev/airflow_learning/airflow_home/dags
Run Code Online (Sandbox Code Playgroud)

Meg*_*Ray 7

在我看来,您有多个 Airflow 安装。我认为您必须在 Admin -> Configuration 菜单中检查 UI。

这将告诉您哪个 Airflow 处于活动状态并设置为AIRFLOW_HOMEAIRFLOW_CONFIG

如果AIRFLOW_CONFIG未设置环境变量,它将始终默认为您的主目录。你必须将它设置为是这样的: AIRFLOW_CONFIG=$AIRFLOW_HOME/airflow.cfg