Integration testing ด้วย dag.test()

Integrity test ตรวจสอบการโหลดข้อมูล และ unit test ตรวจสอบ logic แต่ทั้งสองแบบไม่ได้รัน Dag จริง Integration test ด้วย dag.test() เติมเต็มช่องว่างนี้ โดยรันทุก task ตามลำดับในกระบวนการเดียว มี ETL pipeline ชื่อ etl_output ที่ถูก deploy ไว้แล้ว และเขียนผลลัพธ์ไปที่ /tmp/etl_results.json

ให้เขียน integration test ที่ทดสอบ pipeline ทั้งหมดและตรวจสอบผลลัพธ์ที่ได้