CommencezCommencez gratuitement

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 :

  1. Dans l'affichage Dags, activez complaint_router et déclenchez une exécution.
  2. Ouvrez l'exécution la plus récente et attendez que la tâche route_complaint affiche l'état deferred.
  3. Dans l'onglet Required Actions, sélectionnez Billing Issue et soumettez votre réponse.
  4. 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

Voir le cours

Exercice interactif pratique

Passez de la théorie à l’action grâce à l’un de nos exercices interactifs

Commencer l’exercice