1. Učit se
    2. /
  2. Kurzy
    3. /
  3. Úvod do Apache Airflow v Pythonu
Connected

Cvičení

Implementace pravidla spuštění (Trigger Rule)

Po vytvoření workflow zjistíš, že by DAG těžil z notifikací v případě, kdy selže alespoň jeden úkol. Rozhodneš se proto implementovat úkol s kontrolou one failed, který tě upozorní, pokud v DAGu selže jakýkoli úkol.

Všechny ostatní úkoly jsou již definované a objekty task i dag jsou za tebe naimportované.

Pokyny

100 XP
  • Naimportuj příslušnou knihovnu pro práci s pravidly spuštění (trigger rules).
  • Přidej odpovídající atribut trigger rule k úkolu notify_on_failure.
  • Nastav atribut tak, aby se úkol spustil, když selže jeden nebo více upstream úkolů.
  • Nastav notify_on_failure jako downstream závislost obou transformačních úkolů.