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

exercițiu

Definește un @task.branch

După ce ai aflat despre puterea logicii condiționale în Airflow, vrei să testezi decoratorul @task.branch. Îți dorești să rulezi un traseu de cod diferit dacă data curentă de execuție reprezintă un an nou (de exemplu, 2026 față de 2025).

DAG-ul este deja definit pentru tine, împreună cu taskurile relevante. Sarcina ta acum este să implementezi @task.branch.

Instrucțiuni

100 XP
  • Adaugă variabilele de șablon de dată Airflow corespunzătoare ca parametri ai funcției year_check, pentru a compara anul de execuție curent cu cel anterior.
  • Atribuie valorile current_year și previous_year prin extragerea primelor 4 caractere din fiecare parametru de dată.
  • Setează dependențele față de current_year_task și new_year_task.