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)
在我看来,您有多个 Airflow 安装。我认为您必须在 Admin -> Configuration 菜单中检查 UI。
这将告诉您哪个 Airflow 处于活动状态并设置为AIRFLOW_HOME和AIRFLOW_CONFIG。
如果AIRFLOW_CONFIG未设置环境变量,它将始终默认为您的主目录。你必须将它设置为是这样的:
AIRFLOW_CONFIG=$AIRFLOW_HOME/airflow.cfg。