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:
- Na visualização Dags, ative
complaint_routere dispare uma execução. - Abra a execução mais recente e aguarde até que a tarefa
route_complaintfique no estado deferred. - Na guia Required Actions, selecione Billing Issue e envie sua resposta.
- 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
exercicio interativo prático
Transforme teoria em prática com um dos nossos exercicio interativos
Iniciar exercicio