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

exercițiu

Implementarea unei funcții de callback

Ai primit recent sarcina de a adăuga callback-uri de eșec la DAG-urile create de echipa ta. Pentru început, vrei să adaugi un callback simplu care scrie un mesaj în jurnalul de audit atunci când sales_etl_dag eșuează.

Obiectele dag și task sunt deja importate, iar taskurile get_sales_data și process_sales_data au fost deja create.

Instrucțiuni

100 XP
  • Creează o funcție de callback numită alert_on_failure.
  • Definește funcția astfel încât să accepte orice obiecte transmise de Airflow.
  • Specifică un callback de eșec folosind funcția alert_on_failure.