Pasar datos con XCom

Estás actualizando un flujo ETL para usar un XCom y así llevar un mejor seguimiento de la información. Para ello, necesitas actualizar las dependencias entre las tareas de tu Dag.

Ya tienes cuatro tareas definidas que se usan de la siguiente manera:

extract() - Devuelve order_data
transform(order_data) - Devuelve datos resumidos
load(summary_data) - No devuelve información XCom
send_report() - Una tarea que no usa XCom y gestiona las notificaciones

Este ejercicio forma parte del curso

Introducción a Apache Airflow en Python

Ver curso

Instrucciones del ejercicio

Inserta la tarea transform entre extract() y load() para completar la cadena.
Asigna el resultado a una variable llamada etl_result.
Haz que send_report se ejecute después de la variable etl_result.

Ejercicio interactivo práctico

Prueba este ejercicio y completa el código de muestra.

@dag(start_date=datetime(2026,4,1))
def etl_example():
    # Chain extract, transform, and load, assigning the result
    ____ = load(____(extract()))
    # Run send_report after the ETL tasks
    etl_result ____ ____()
    
etl_example()

Editar y ejecutar código