未被调度器选择的气流包装dags(Zip)

Question

我正在尝试将封装dag与Celery Executor结合使用，但是调度程序和工作人员并没有完成这项工作。我重新启动了airflow webserver和airflow scheduler，但仍然没有成功。我甚至用airflow resetdb重置了DB，但仍然什么也没有。

我收到以下讯息：-

[INFO] Handling signal: ttou
[INFO] Worker exiting (pid: 31418)
[INFO] Handling signal: ttin
[INFO] Booting worker with pid: 32308

DAGs没有手动运行，甚至没有被调度程序选中。

​

​

我的zip文件有以下内容：

unzip alerting.zip   

creating: airflow_utils/
inflating: airflow_utils/enums.py  
inflating: airflow_utils/psql_alerting_dag.py  
extracting: airflow_utils/__init__.py  
inflating: airflow_utils/hive_alerting_dag.py  
inflating: airflow_utils/alerting_utils.py  
inflating: alerting_12hrs.py       
inflating: alerting_15mins.py      
inflating: alerting_3hrs.py 

如果我将所有这些文件放置在dags文件夹中而不是打包它们，那么气流调度程序就可以调度dags.。

我有什么不对的吗？

Answer 1

我是在1.8.1气流，这有问题的装载达格从拉链。这一问题在1.8.3中得到了解决。https://issues.apache.org/jira/browse/AIRFLOW-1357