使用 dag.test() 進行整合測試

整體性測試會檢查載入是否正確，單元測試會檢查邏輯是否正確，但兩者都不會實際執行整個 Dag。使用 dag.test() 的整合測試能補上這個缺口，因為它會在單一行程中依序執行所有工作。有一個名為 etl_output 的 ETL 管線已部署，會把結果寫入 /tmp/etl_results.json。

你將撰寫一個整合測試，完整跑過整條管線，並驗證其輸出。