如何使用 DAG 集群策略为所有 dag 设置默认值？答案

【问题标题】：How to set default value for all dags with DAG cluster policy?如何使用 DAG 集群策略为所有 dag 设置默认值？
【发布时间】：2021-04-20 14:20:22
【问题描述】：

我正在尝试为我的所有 dag 设置两个默认值。为此，我使用以下代码在我的 Airflow 主目录中创建了文件airflow_local_settings.py（尝试遵循https://airflow.apache.org/docs/apache-airflow/stable/concepts.html#dag-level-cluster-policy 中的示例）：

def dag_policy(dag: DAG):
    dag.catchup = False
    dag.default_args['email'] = 'blabla'

但是，我得到了错误：

Error: name 'DAG' is not defined

如果我将代码保留为：

def dag_policy(dag: DAG):
        dag.catchup = False
        dag.default_args['email'] = 'blabla'

然后 dags 运行 catchup=True 并且没有电子邮件。我该如何解决？谢谢

【问题讨论】：

标签： airflow

【解决方案1】：

DAG 策略已添加到 PR，并且仅在 Airflow >= 2.0 中可用，因为您运行的是 1.10.14，此功能对您不可用。

【讨论】：