Konvertera en klassisk DAG till TaskFlow

Ditt team har beslutat att använda TaskFlow API för alla nya pipelines. Din chef ber dig skriva om en befintlig ETL-pipeline som använde PythonOperator med manuell >>-koppling.

Den ursprungliga klassiska versionen finns som referens i dags/classic_etl.py. En färdigstrukturerad TaskFlow-version är redo för dig att slutföra.