Definir el orden de las tareas
Ahora que has aprendido la sintaxis de desplazamiento de bits, es hora de definir el orden de las tareas. Tienes tres tareas definidas: cleanup, consolidate y push_data.
Los decoradores dag y task de airflow.sdk ya están importados.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Configura la tarea
cleanuppara que se ejecute primero, antes que la tareaconsolidate, usando la sintaxis de desplazamiento de bits. - Configura
consolidatepara que se ejecute después y la tareapush_datapara que se ejecute al final.
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()