使用 dag.test() 进行集成测试

完整性测试用于核对加载，单元测试用于验证逻辑，但两者都不会实际运行 Dag。使用 dag.test() 的集成测试能弥补这一点，它会在单个进程中按顺序执行所有任务。一个名为 etl_output 的 ETL 管道已部署，并将结果写入 /tmp/etl_results.json。

您将编写一个集成测试来跑通整个管道，并验证其输出。