Airflow Scheduler

• DAG를 분석
• DAG의 예약 주기 확인
• 예약 주기가 현 시점보다 이전이면 worker에 DAG의 task를 예약
• 예약된 task의 업스트림 의존성(이전 태스크가 완료되었는지 여부) 확인
• 의존성이 모두 해결된 상태면 실행 대기열에 추가함

Airflow Worker

• 대기열에 예약된 task를 선택하고 실행함
• 실행한 task의 결과를 반환함 결과는 Airflow 메타스토어(DB)에 저장됨

Ariflow Web Server

• scheduler가 분석한 DAG 시각화
• 사용자가 DAG를 실행시키고 결과를 모니터링할 수 있는 인터페이스 제공