1. 학습
    2. /
  2. 강의
    3. /
  3. Giới thiệu về Apache Airflow bằng Python
Connected

연습 문제

Triển khai Trigger Rule

Sau khi tạo một workflow, bạn nhận ra Dag sẽ hữu ích hơn nếu cung cấp cập nhật khi có ít nhất một task thất bại. Bạn quyết định thêm một task thực hiện kiểm tra one failed trên Dag để cảnh báo bạn nếu bất kỳ task nào trong Dag bị lỗi.

Tất cả các task khác đã được định nghĩa và các đối tượng task & dag đã được nhập sẵn cho bạn.

지침

100 XP
  • Import thư viện phù hợp để dùng trigger rules.
  • Thêm thuộc tính trigger rule thích hợp cho task notify_on_failure.
  • Thiết lập thuộc tính để task được kích hoạt khi một hoặc nhiều task upstream thất bại.
  • Đặt notify_on_failure là phụ thuộc downstream của hai task transform.