气流：如何为任务失败设置全局默认电子邮件？

Question

在我的环境中，大多数任务失败警报应该发送到特定的开发人员/开发人员组列表

我可以将这些电子邮件发送到每个DAG，如：

default_args = {
    'email': ['dev1@test.com', 'dev2@test.com', 'dev3@test.com'],
    ...
}

with DAG(
    'TestDagWithEmail',
    default_args=default_args,
    ...
) as dag:
  ...

但是，是否有任何选项可以避免在我创建的每个DAG中指定'email'（在需要时可以重写）？
我想在{}找些环境，但运气不好

气流版本：1.10.10

Answer 1

目前，没有电子邮件的配置，但您可以对任务使用群集策略，如下所示：

阅读更多：https://airflow.readthedocs.io/en/1.10.14/concepts.html#cluster-policies-for-task-mutation

def policy(task):
    task.email = ['dev1@test.com', 'dev2@test.com', 'dev3@test.com']