Перетворення класичного Dag на TaskFlow

Ваша команда вирішила використовувати TaskFlow API для всіх нових конвеєрів. Керівник просить вас переписати наявний ETL‑конвеєр, який використовував PythonOperator з ручним з'єднанням через >>.

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