태스크 실행 순서 정의하기
비트시프트 구문에 대해 배웠으니, 이제 태스크 실행 순서를 정의해 볼 차례입니다. 현재 cleanup, consolidate, push_data 세 가지 태스크가 정의되어 있습니다.
airflow.sdk에서 dag와 task 데코레이터는 이미 임포트되어 있습니다.
이 연습은 강의의 일부입니다
Python으로 배우는 Apache Airflow 입문
연습 안내
- 비트시프트 구문을 사용하여
cleanup태스크가consolidate태스크보다 먼저 실행되도록 설정하세요. consolidate가 그다음에 실행되고,push_data태스크가 마지막에 실행되도록 설정하세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()