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

cvičení

Implementace callback funkce

Nedávno ti bylo přiděleno doplnit failure callbacky do DAGů vytvořených tvým týmem. Pro začátek chceš přidat jednoduchý failure callback, který zapíše zprávu do audit logu vždy, když sales_etl_dag selže.

Objekty dag a task jsou již naimportovány a úlohy get_sales_data a process_sales_data jsou připraveny.

Pokyny

100 XP
  • Vytvoř callback funkci s názvem alert_on_failure.
  • Definuj funkci tak, aby přijímala libovolné objekty, které jí Airflow předá.
  • Zadej failure callback pomocí funkce alert_on_failure.