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

演習

トリガールールの実装

ワークフローを作成した後、少なくとも1つのタスクが失敗した際に通知を送ると便利だと気づきました。そこで、DAG内のいずれかのタスクが失敗した場合に警告を出す one failed チェックを実装したタスクを追加することにします。

他のタスクはすでに定義済みで、task オブジェクトと dag オブジェクトもインポートされています。

指示

100 XP
  • トリガールールを使用するために必要なライブラリをインポートします。
  • notify_on_failure タスクに適切なトリガールール属性を追加します。
  • 上流タスクの1つ以上が失敗したときにタスクがトリガーされるよう属性を設定します。
  • notify_on_failure を2つの変換タスクの下流依存関係として設定します。