如何在不需要重启气流网络服务器的情况下更新气流中的python函数

Question

我正在学习使用气流来调度一些python ETL过程。每次我更新我的Python代码时，我必须重新启动Web服务器，并在代码更改被气流拾取之前重命名DAG。反正有没有，特别是当我每次进行修改时都不需要重命名我的DAG？

Answer 1

在网络服务器上，更改可能并不明显，但您可以单击您修改的DAG旁边的刷新按钮，它将手动重新加载DAG。

调度程序将始终使用最新的代码，而无需重新启动。

在这里看到：https://gtoonstra.github.io/etl-with-airflow/gotchas.html

Answer 2

此网址： http://airflowhost:8080/admin/airflow/refresh_all

刷新所有的DAG

Answer 3

这已经与当前版本的问题。我通常所做的就是复制DAG并更改它的名称，使其反映在Web服务器中。一旦我完成开发，我会保持最后一次重命名并删除旧的。