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

Định nghĩa một @task.branch

Sau khi tìm hiểu về sức mạnh của logic điều kiện trong Airflow, bạn muốn thử decorator @task.branch. Bạn muốn chạy nhánh mã khác nếu ngày thực thi hiện tại rơi vào năm mới (ví dụ, 2026 so với 2025).

Dag đã được định nghĩa sẵn, cùng với các task liên quan. Nhiệm vụ hiện tại của bạn là triển khai @task.branch.

Hướng dẫn

100 XP
  • Thêm các biến template ngày tháng của Airflow phù hợp làm tham số cho year_check để so sánh năm thực thi hiện tại và trước đó.
  • Gán current_year và previous_year bằng cách cắt 4 ký tự đầu tiên từ mỗi tham số ngày.
  • Thiết lập phụ thuộc cho current_year_task và new_year_task.