1. 学ぶ
  2. /
  3. コース
  4. /
  5. Python で学ぶ Apache Airflow 入門

Connected

演習

人間による承認の追加

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

dag、task、および timedelta オブジェクトはあらかじめインポートされています。

指示

100 XP
  • 承認/却下タスクを作成するための適切なライブラリをインポートしてください。
  • approve_gate 承認タスクを作成してください。
  • Airflow UI でレビュアーに表示される承認リクエストのタイトルを設定してください。