1. Apprendre
    2. /
  2. Cours
    3. /
  3. Introduction à Apache Airflow en Python
Connected

Exercice

Implémenter une règle de déclenchement

Après avoir créé un flux de travail, vous réalisez que le Dag gagnerait à envoyer des mises à jour lorsqu'au moins une tâche échoue. Vous décidez d'ajouter une tâche qui applique la vérification one failed sur votre Dag pour vous alerter si une tâche du Dag échoue.

Toutes les autres tâches ont été définies et les objets task et dag sont déjà importés pour vous.

Instructions

100 XP
  • Importez la bibliothèque appropriée pour utiliser les règles de déclenchement (trigger rules).
  • Ajoutez l'attribut de règle de déclenchement approprié à la tâche notify_on_failure.
  • Réglez l'attribut pour que la tâche se déclenche lorsqu'une ou plusieurs tâches en amont échouent.
  • Définissez notify_on_failure comme dépendance en aval des deux tâches de transformation.