사람의 승인 단계 추가하기
워크플로우 작업 중, 팀장이 영업팀 분석 데이터베이스에 데이터를 게시하는 과정에서 문제가 발생했다고 언급합니다. 데이터 웨어하우스에 게시하기 전에 영업 데이터가 올바른지 확인하고 싶다고 합니다. 데이터 삽입 전 최종 검토 단계로 HITL(Human-in-the-Loop) 승인 단계를 추가하면 좋겠다는 생각이 듭니다.
dag, task, timedelta 객체는 이미 임포트되어 있습니다.
이 연습은 강의의 일부입니다
Python으로 배우는 Apache Airflow 입문
연습 안내
- 승인/거부 태스크를 생성하기 위한 적절한 라이브러리를 임포트하세요.
approve_gate승인 태스크를 생성하세요.- Airflow UI에서 검토자에게 표시될 승인 요청 제목을 설정하세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
# Import ApprovalOperator
from airflow.providers.standard.operators.____ import ____
@dag(start_date=datetime(2026,4,15))
def data_warehouse_dag():
# Create the approve_gate approval task
approve_gate = ____(
task_id="approve_sales_data",
# Set the title for the approval request shown to the reviewer
____="Sales data processing - Approval Required",
body=(
"Please review the sales data produced by the *pull_raw_data* task."
"Approve to push leads to the data warehouse, or Reject to halt the run."
),
)
pull_raw_data() >> approve_gate >> push_to_warehouse()
data_warehouse_dag()