Branchement avec HITLBranchOperator
Un pipeline d'orientation des réclamations utilise HITLBranchOperator pour permettre à une personne de choisir quelle équipe traite chaque ticket. Le Dag est déployé — déclenchez une exécution, choisissez une branche, et voyez comment Airflow gère le reste.
Suivez ces étapes :
- Dans la vue Dags, activez
complaint_routeret déclenchez une exécution. - Ouvrez la dernière exécution 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 à la vue Graph et regardez l'état de chaque tâche.
Après avoir sélectionné « Billing Issue », que se passe-t-il pour les tâches que vous n'avez pas sélectionnées ?
Cet exercice fait partie du cours
<cours>Créer des pipelines de données avec Airflow</cours>Exercice interactif pratique
Transformez la théorie en action avec l’un de nos exercices interactifs
Commencer l’exercice