人間による承認の追加
ワークフローの作業中に、営業チームの分析データベースに投稿されるデータに問題が発生しているという連絡を上司から受けました。データウェアハウスに投稿する前に、売上データが正しいことを確認したいとのことです。そこで、データ挿入前の最終確認として、HITL（人間が介在するループ）による承認ステップを追加するのが良いと判断しました。
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()