Cvičení

Definuj @task.branch

Po tom, co ses naučil/a o síle podmínkové logiky v Airflow, si chceš vyzkoušet dekorátor @task.branch. Cílem je spustit jiný kód v případě, že aktuální datum spuštění představuje nový rok (tj. 2026 místo 2025).

DAG je již definován spolu s potřebnými úlohami. Tvým úkolem je implementovat @task.branch.

Pokyny

100 XP

Přidej do year_check příslušné Airflow šablonové proměnné pro datum jako parametry, aby bylo možné porovnat aktuální a předchozí rok spuštění.
Přiřaď current_year a previous_year tak, že z každého datového parametru vyřízneš prvních 5 znaků.
Nastav závislosti pro current_year_task a new_year_task.

.css-6su6fj{-webkit-flex-shrink:0;-ms-flex-negative:0;flex-shrink:0;}Cvičení

Pokyny

Cvičení