Un callback est une fonction appelée automatiquement par Airflow lors d'un événement : échec, succès ou reprise d'une tâche ou d'un DAG (on_failure_callback, on_success_callback). Il sert à envoyer une alerte, journaliser ou déclencher une action corrective, avec accès au contexte de l'exécution.
Exemple
def alerte(context):
print('Échec :', context['task_instance'].task_id)