1. 학습
    2. /
  2. 강의
    3. /
  3. Python으로 배우는 Apache Airflow 입문
Connected

연습 문제

BranchPythonOperator 정의하기

Airflow에서 조건문 로직의 강력함을 배운 뒤, BranchPythonOperator를 시험해 보려고 해요. 현재 실행 날짜가 새해를 의미하는 경우(예: 2019에서 2020으로 바뀌는 경우) 다른 코드 경로를 실행하고 싶어요.

DAG와 관련 태스크는 이미 정의되어 있어요. 지금 해야 할 일은 BranchPythonOperator를 구현하는 것입니다.

지침

100 XP
  • year_check 함수에서, 현재 실행 날짜의 연도가 이전 실행 날짜의 연도와 다른지 판별하도록 코드를 구성하세요(즉, 적절한 Airflow 템플릿 변수를 사용해 두 날짜의 연도를 비교하세요).
  • 적절한 인수를 추가해 BranchPythonOperator를 완성하세요.
  • current_year_task와 new_year_task의 의존성을 설정하세요.