Añadir aprobación humana
Mientras trabajas en un flujo de trabajo, tu jefa menciona que ha habido problemas con los datos que se publican en la base de datos de analítica del equipo de ventas. Quieren asegurarse de que los datos de ventas tienen buena pinta antes de cargarlos en un almacén de datos. Te das cuenta de que un paso de aprobación HITL es una buena opción para añadir una última comprobación antes de insertar los datos.
Los objetos dag, task y timedelta ya se han importado por ti.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Importa la biblioteca adecuada para crear una tarea de Aprobar / Rechazar.
- Crea la tarea de aprobación
approve_gate. - Establece el título de la solicitud de aprobación que verá la persona revisora en la interfaz de Airflow.
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
# 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()