1. Learn
    2. /
  2. Cursuri
    3. /
  3. Introducere în Apache Airflow în Python
Connected

exercițiu

Adăugarea reîncercărilor

Ai observat că un anumit DAG eșuează frecvent la o sarcină care extrage date dintr-o sursă. Surprinzător, rularea sarcinii câteva minute mai târziu pare să rezolve problema. După ce ai aflat despre funcționalitatea de reîncercare din DAG-urile Airflow, decizi să implementezi reîncercări pentru această sarcină, pentru a nu mai fi nevoit să o repornești manual.

dag, task și timedelta sunt deja importate pentru tine.

Instrucțiuni

100 XP
  • Setează sarcina extract_data să se reîncerce de 3 ori înainte de a eșua.
  • Adaugă o întârziere de 10 minute între reîncercări pentru sarcina extract_data.