Bifurcation avec HITLBranchOperator
Un pipeline d'acheminement des plaintes utilise HITLBranchOperator pour permettre à une personne de choisir quelle équipe traite chaque billet. Le Dag est déployé — déclenchez une exécution, choisissez une branche et voyez comment Airflow s'occupe du reste.
Suivez ces étapes :
- Dans l'affichage Dags, activez
complaint_routeret déclenchez une exécution. - Ouvrez l'exécution la plus récente et attendez que la tâche
route_complaintaffiche l'état deferred. - Dans l'onglet Required Actions, sélectionnez Billing Issue et soumettez votre réponse.
- Passez à l'affichage Graph et regardez l'état de chaque tâche.
Après avoir sélectionné « Billing Issue », qu'arrive-t-il aux tâches que vous n'avez pas sélectionnées ?
Cette activité fait partie du cours
Créer des pipelines de données avec Airflow
Exercice interactif pratique
Passez de la théorie à l’action grâce à l’un de nos exercices interactifs
Commencer l’exercice