1. Học hỏi
  2. /
  3. Khoa Học
  4. /
  5. Giới thiệu về Apache Airflow bằng Python

Connected

Bài tập

Kích hoạt một Dag con

Bạn nhận thấy một số workflow đang dùng những thành phần tương tự và nhận ra bạn có thể tách các tác vụ dùng chung thành một Dag riêng. Cách này cho phép bạn chạy các thành phần đó khi cần mà không phải duy trì nhiều bản sao. Bạn quyết định thực thi một Dag con thông qua một task trong workflow hiện tại.

Các thành phần dag, task, và datetime đã được import sẵn cho bạn.

Hướng dẫn

100 XP
  • Import operator cần thiết để khởi động một Dag từ trong workflow của bạn.
  • Thiết lập operator để kích hoạt Dag có tên child_pipeline.
  • Đảm bảo Dag cha chờ Dag đã kích hoạt hoàn tất trước khi tiếp tục.
  • Thiết lập tần suất operator kiểm tra xem Dag con đã hoàn thành hay chưa.