Convertendo um Dag clássico para TaskFlow

Sua equipe decidiu adotar a TaskFlow API para todos os novos pipelines. Sua gerente pediu para você reescrever um pipeline de ETL existente que usava PythonOperator com encadeamento manual por >>.

A versão clássica original está disponível como referência em dags/classic_etl.py. Uma versão com estrutura inicial em TaskFlow está pronta para você concluir.