Adicionando aprovação humana
Enquanto trabalha em um workflow, sua chefe menciona que têm ocorrido problemas com os dados enviados para o banco de dados de analytics da equipe de vendas. Eles querem ter certeza de que os dados de vendas estão corretos antes de enviá-los para um data warehouse. Você percebe que um passo de aprovação HITL é uma boa opção para adicionar uma última checagem antes da inserção dos dados.
Os objetos dag, task e timedelta já foram importados para você.
Este exercício faz parte do curso
Introdução ao Apache Airflow em Python
Instruções do exercício
- Importe a biblioteca apropriada para criar uma tarefa de Aprovar / Rejeitar.
- Crie a tarefa de aprovação
approve_gate. - Defina o título da solicitação de aprovação que aparecerá para o revisor na interface do Airflow.
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
# Import ApprovalOperator
from airflow.providers.standard.operators.____ import ____
@dag(start_date=datetime(2026,4,15))
def data_warehouse_dag():
# Create the approve_gate approval task
approve_gate = ____(
task_id="approve_sales_data",
# Set the title for the approval request shown to the reviewer
____="Sales data processing - Approval Required",
body=(
"Please review the sales data produced by the *pull_raw_data* task."
"Approve to push leads to the data warehouse, or Reject to halt the run."
),
)
pull_raw_data() >> approve_gate >> push_to_warehouse()
data_warehouse_dag()