Implémentation d’un branching conditionnel dans un DAG

Scénario

Contexte : Selon un paramètre d’entrée, le pipeline doit exécuter un traitement standard ou un traitement avancé. Le Problème : Le DAG actuel exécute systématiquement les deux branches. Contraintes : Utiliser BranchPythonOperator ou TaskFlow API pour définir un branchement conditionnel. Garantir que seule la branche sélectionnée s’exécute. Livrable attendu : Proposer une implémentation permettant un contrôle conditionnel du flux d’exécution dans le DAG.

Compétences ciblées