Aan de slagBegin gratis

Converting a classic Dag to TaskFlow

Your team has decided to adopt the TaskFlow API for all new pipelines. Your manager asks you to rewrite an existing ETL pipeline that used PythonOperator with manual >> wiring.

The original classic version is available as a reference in dags/classic_etl.py. A scaffolded TaskFlow version is ready for you to complete.

Deze oefening maakt deel uit van de cursus

Building Data Pipelines with Airflow

Bekijk cursus

Interactieve oefening met praktijkervaring

Zet theorie om in actie met een van onze interactieve oefeningen

Begin oefening