Conversia unui Dag clasic la TaskFlow

Echipa ta a decis să adopte TaskFlow API pentru toate pipeline-urile noi. Managerul tău îți cere să rescrii un pipeline ETL existent, care folosea PythonOperator cu conexiuni manuale prin >>.

Versiunea clasică originală este disponibilă ca referință în dags/classic_etl.py. O versiune TaskFlow pregătită parțial așteaptă să fie completată de tine.