Flujo de air predeterminado on_failure_callback

En mi archivo DAG, he definido una función on_failure_callback () para publicar un Slack en caso de falla.

Funciona bien si especifico para cada operador en mi DAG: on_failure_callback = on_failure_callback ()

¿Hay alguna forma de automatizar (a través de default_args, por ejemplo, o a través de mi objeto DAG) el envío a todos mis operadores?

Finalmente encontré una manera de hacer eso.

Puedes pasar tu on_failure_callback como un default_args

class Foo: @staticmethod def get_default_args(): """ Return default args :return: default_args """ default_args = { 'on_failure_callback': Foo.on_failure_callback } return default_args @staticmethod def on_failure_callback(context): """ Define the callback to post on Slack if a failure is detected in the Workflow :return: operator.execute """ operator = SlackAPIPostOperator( task_id='failure', text=str(context['task_instance']), token=Variable.get("slack_access_token"), channel=Variable.get("slack_channel") ) return operator.execute(context=context)