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.
Latihan ini merupakan bagian dari kursus
Building Data Pipelines with Airflow
Latihan interaktif langsung
Ubah teori menjadi aksi dengan salah satu latihan interaktif kami
Mulai latihan