1. Nauka
    2. /
  2. Kursy
    3. /
  3. Wprowadzenie do Apache Airflow w Pythonie
Connected

ćwiczenie

Implementacja reguły wyzwalania

Po utworzeniu przepływu pracy zauważasz, że DAG zyska na tym, jeśli będzie wysyłać powiadomienia w przypadku niepowodzenia co najmniej jednego zadania. Postanawiasz zaimplementować zadanie korzystające z kontroli one failed, które powiadomi cię o niepowodzeniu któregokolwiek zadania w DAG-u.

Wszystkie pozostałe zadania zostały już zdefiniowane, a obiekty task i dag są zaimportowane.

Instrukcje

100 XP
  • Zaimportuj odpowiednią bibliotekę do obsługi reguł wyzwalania.
  • Dodaj odpowiedni atrybut reguły wyzwalania do zadania notify_on_failure.
  • Ustaw atrybut tak, aby zadanie uruchamiało się, gdy co najmniej jedno zadanie upstream zakończy się niepowodzeniem.
  • Ustaw notify_on_failure jako zależność downstream obu zadań transformacji.