如何检查 DAG 是否已经存在？
How to check if a DAG already exists?
我想弄清楚 - 是否可以验证气流中是否已经存在 DAG。例如-如果存在名为“dag_execution_1”的现有 DAG；我想要某种程序来停止上传具有相同名称的新 DAG。
可能吗？
在Airflow>=2.1.0中已经处理了。
如果发现重复 dag_id 将提高 AirflowDagDuplicatedIdException
请注意，该指示仅适用于 DAG 处理器。正如 https://github.com/apache/airflow/pull/17891
中所讨论的那样，很难在所有 Airflow 中处理它
我想弄清楚 - 是否可以验证气流中是否已经存在 DAG。例如-如果存在名为“dag_execution_1”的现有 DAG；我想要某种程序来停止上传具有相同名称的新 DAG。 可能吗？
在Airflow>=2.1.0中已经处理了。
如果发现重复 dag_id 将提高 AirflowDagDuplicatedIdException
请注意，该指示仅适用于 DAG 处理器。正如 https://github.com/apache/airflow/pull/17891