dag.test() を使った統合テスト

整合性テストはデータの読み込みを検証し、単体テストはロジックを検証しますが、どちらも実際に DAG を実行するわけではありません。dag.test() を使った統合テストは、すべてのタスクを単一プロセス内で順番に実行することで、その差を埋めます。etl_output という ETL パイプラインがデプロイされており、/tmp/etl_results.json に結果を書き出します。

ここでは、パイプライン全体を実行し、その出力を検証する統合テストを作成しましょう。