การเขียน TaskFlow Dag แบบขั้นต่ำ

ทีมของคุณกำลังเริ่มต้นโปรเจกต์ data pipeline ใหม่ ก่อนที่จะสร้าง pipeline เต็มรูปแบบ หัวหน้าขอให้ตั้งค่า Dag แบบขั้นต่ำเพื่อตรวจสอบว่า environment ทำงานได้ถูกต้อง

ไฟล์แบบฝึกหัดมี dag.test() อยู่ที่ด้านล่าง ซึ่งจะรัน Dag ทั้งหมดในกระบวนการเดียว เพื่อให้ดูผลลัพธ์ของแต่ละ task ได้โดยตรง