Mensaje flojo fallido del flujo de aire

¿Cómo puedo configurar Airflow para que cualquier falla en el DAG resulte (inmediatamente) en un mensaje flojo?

En este momento lo manejo creando una slack_failed_task:

slack_failed_task =  SlackAPIPostOperator(
    task_id='slack_failed',
    channel="#datalabs",
    trigger_rule='one_failed',
    token="...",
    text = ':red_circle: DAG Failed',
    icon_url = 'http://airbnb.io/img/projects/airflow3.png',
    dag=dag)

Y configure esta tarea (one_failed) aguas arriba de cada tarea en el DAG:

slack_failed_task << download_task_a
slack_failed_task << download_task_b
slack_failed_task << process_task_c
slack_failed_task << process_task_d
slack_failed_task << other_task_e

Funciona, pero es propenso a errores, ya que olvidarse de agregar la tarea omitirá las notificaciones flojas y parece mucho trabajo.

¿Hay tal vez una manera de ampliar elemail_on_failure propiedad en el DAG?

Bonus ;-) por incluir una forma de pasar el nombre de la tarea fallida al mensaje.

Respuestas a la pregunta(3)

Su respuesta a la pregunta