Převod klasického DAGu na TaskFlow

Tvůj tým se rozhodl používat TaskFlow API pro všechny nové pipelines. Manažer tě požádal, abys přepsal/a existující ETL pipeline, která využívala PythonOperator s ručním zapojením pomocí >>.

Originální klasická verze je k dispozici jako reference v dags/classic_etl.py. Připravená kostra ve verzi s TaskFlow čeká na tvoje doplnění.