Viết một TaskFlow Dag tối giản

Nhóm của bạn đang bắt đầu một dự án pipeline dữ liệu mới. Trước khi xây dựng đầy đủ, trưởng nhóm yêu cầu bạn thiết lập một Dag tối giản để kiểm tra môi trường hoạt động bình thường.

Tệp bài tập có dag.test() ở cuối, chạy toàn bộ Dag trong một tiến trình để bạn có thể xem trực tiếp đầu ra của các task.