Comece agoraComece grátis

Ramificação com HITLBranchOperator

Um pipeline de roteamento de reclamações usa HITLBranchOperator para permitir que uma pessoa escolha qual equipe trata cada chamado. A Dag já está implantada — dispare uma execução, escolha um branch e veja como o Airflow cuida do resto.

Siga estes passos:

  1. Na visualização Dags, ative complaint_router e dispare uma execução.
  2. Abra a execução mais recente e aguarde até que a tarefa route_complaint fique no estado deferred.
  3. Na guia Required Actions, selecione Billing Issue e envie sua resposta.
  4. Mude para a visualização Graph e observe o estado de cada tarefa.

Depois de selecionar "Billing Issue", o que acontece com as tarefas que você não selecionou?

Este exercicio faz parte do curso

Criando Pipelines de Dados com Airflow

Ver curso

exercicio interativo prático

Transforme teoria em prática com um dos nossos exercicio interativos

Iniciar exercicio