1. Nauka
    2. /
  2. Kursy
    3. /
  3. Introducere în Apache Airflow în Python
Connected

ćwiczenie

Implementarea unei reguli de declanșare

După ce ai creat un workflow, îți dai seama că DAG-ul ar beneficia de notificări atunci când cel puțin un task eșuează. Decizi să implementezi un task care aplică verificarea one failed în DAG-ul tău, pentru a primi o alertă dacă vreun task eșuează.

Toate celelalte taskuri au fost deja definite, iar obiectele task și dag sunt deja importate pentru tine.

Instrukcje

100 XP
  • Importă biblioteca corespunzătoare pentru a folosi regulile de declanșare.
  • Adaugă atributul corespunzător regulii de declanșare la taskul notify_on_failure.
  • Setează atributul astfel încât taskul să se declanșeze când unul sau mai multe taskuri din amonte eșuează.
  • Setează notify_on_failure ca dependență din aval față de cele două taskuri de transformare.