將傳統 Dag 轉換為 TaskFlow

你的團隊決定在所有新管線上採用 TaskFlow API。你的主管請你把一個現有使用 PythonOperator 並以手動 >> 串接的 ETL 管線重寫成新版本。

原始的傳統版本可在 dags/classic_etl.py 參考。已為你準備好一個雛形的 TaskFlow 版本，等你完成。