Konwersja klasycznego DAG-a do TaskFlow

Twój zespół postanowił używać TaskFlow API we wszystkich nowych pipeline'ach. Menedżer prosi cię o przepisanie istniejącego pipeline'u ETL, który korzystał z PythonOperator i ręcznego łączenia zadań operatorem >>.

Oryginalna, klasyczna wersja jest dostępna jako punkt odniesienia w pliku dags/classic_etl.py. Przygotowano już szkielet wersji opartej na TaskFlow — twoje zadanie to go uzupełnić.