クラシック Dag の TaskFlow への変換

チームでは、新しいパイプラインにはすべて TaskFlow API を採用することにしました。マネージャーから、PythonOperator と手動の >> 配線を使って作成された既存の ETL パイプラインを書き直すよう依頼されました。

オリジナルのクラシックバージョンは dags/classic_etl.py に参照用として保存されています。TaskFlow バージョンの雛形が用意されていますので、完成させましょう。