airflow - 如果更改气流 DAG 会发生什么？

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

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

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

在 0100 运行会生成多少个文件？这里有比赛条件吗？0200 的那个呢？

标签： airflow

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