如果气流 DAG 发生更改，会发生什么情况？

Question

Airflow 监视新 DAG 的 DAG 位置并拾取它们（大约每分钟），而无需重新启动。

如果将更新的 dag 定义上传到 dag 位置会发生什么情况？

假设我有一个名为“foodag”的 dag，它生成 1 个文件，并且每小时运行一次。正好 0100 点，我部署了新版本的“foodag”，它现在生成了 2 个文件。目前有一场活动于 0100 开始，另一场活动于 0200 开始。

在 0100 运行会生成多少个文件？这里有竞争条件吗？0200 的那个怎么样？

Answer 1

如果您在 DAG 当前运行时部署新版本的 DAG，则当前运行的 DAG (0100) 将运行旧版本（生成 1 个文件）。下一次运行 (0200) 将具有最新版本（生成 2 个文件）。