Преобразование классического DAG в TaskFlow

Ваша команда решила использовать TaskFlow API для всех новых пайплайнов. Руководитель просит вас переписать существующий ETL-пайплайн, который использовал PythonOperator с ручной цепочкой зависимостей >>.

Оригинальная классическая версия доступна в качестве справочного материала в dags/classic_etl.py. Заготовка версии на TaskFlow готова — вам нужно её доработать.