1. Apprendre
  2. /
  3. Cours
  4. /
  5. Introduction à Apache Airflow en Python

Connected

Exercice

Définir un @task.branch

Après avoir vu la puissance de la logique conditionnelle dans Airflow, vous souhaitez essayer le décorateur @task.branch. Vous voulez exécuter un chemin de code différent si la date d'exécution actuelle correspond à une nouvelle année (p. ex., 2026 vs 2025).

Le Dag est déjà défini, ainsi que les tâches visées. Votre tâche actuelle est d'implanter le @task.branch.

Instructions

100 XP
  • Ajoutez les variables de gabarit de date d'Airflow appropriées comme paramètres de year_check pour comparer l'année d'exécution actuelle et la précédente.
  • Attribuez current_year et previous_year en découpant les 4 premiers caractères de chaque paramètre de date.
  • Définissez les dépendances sur current_year_task et new_year_task.