始める無料で始める

HITLBranchOperator によるブランチ処理

クレーム振り分けパイプラインでは、HITLBranchOperator を使って、人間がどのチームで各チケットを対応するかを選択できるようになっています。DAG はデプロイ済みです。実際に実行をトリガーし、ブランチを選択して、Airflow がその後どのように処理するかを確認しましょう。

以下の手順に従ってください。

  1. DAG ビューで complaint_router を有効にし、実行をトリガーします。
  2. 最新の実行を開き、route_complaint タスクが deferred 状態になるまで待ちます。
  3. Required Actions タブで Billing Issue を選択し、回答を送信します。
  4. Graph ビューに切り替え、各タスクの状態を確認します。

"Billing Issue" を選択した後、選択しなかったタスクはどうなりますか?

この演習はコースの一部です

Airflow によるデータパイプラインの構築

コースを見る

実践的なインタラクティブ演習

理論を実践に変える、インタラクティブな演習のひとつをお試しください

演習を開始する