ćwiczenie

Definiowanie @task.branch

Po zapoznaniu się z możliwościami logiki warunkowej w Airflow chcesz przetestować dekorator @task.branch. Zależy ci na uruchomieniu innej ścieżki kodu, jeśli bieżąca data wykonania oznacza nowy rok (np. 2026 zamiast 2025).

DAG jest już dla ciebie zdefiniowany, wraz z odpowiednimi zadaniami. Twoim zadaniem jest teraz zaimplementowanie @task.branch.

Instrukcje

100 XP

Dodaj odpowiednie zmienne szablonów dat Airflow jako parametry funkcji year_check, aby porównać bieżący i poprzedni rok wykonania.
Przypisz current_year i previous_year, wycinając pierwsze 4 znaki z każdego parametru daty.
Ustaw zależności dla current_year_task i new_year_task.

.css-6su6fj{-webkit-flex-shrink:0;-ms-flex-negative:0;flex-shrink:0;}ćwiczenie

Instrukcje

ćwiczenie