新的 DAG 或对现有 DAG 的更改不会显示在 Airflow Web 服务器上以供在应用程序中使用。
例如。假设我在 DAG 目录中添加一个新的 DAG:
$ airflow dags list那么 dag 就会出现。select dag_id from dag;,则存在新的 dag。因此它被拾取并放入数据库中。dag_code,源代码没有被更新dag_code。$ airflow db init再次运行,那么更改就会生效并且一切正常......所以我的系统是稳定且可用的,因为我正在破解以下功能:$ airflow db init。由于运行此命令不会影响数据库中的数据,因此我实际上可以像这样工作,只需在每次发生更改时运行该命令即可。但我担心,因为这并没有按预期发挥作用,它可能掩盖了更深层次的问题。
任何帮助将不胜感激。我在下面列出了我的系统规格和气流设置。
airflow.cfg相关参数: …