HITLBranchOperator によるブランチ処理
クレーム振り分けパイプラインでは、HITLBranchOperator を使って、人間がどのチームで各チケットを対応するかを選択できるようになっています。DAG はデプロイ済みです。実際に実行をトリガーし、ブランチを選択して、Airflow がその後どのように処理するかを確認しましょう。
以下の手順に従ってください。
- DAG ビューで
complaint_routerを有効にし、実行をトリガーします。 - 最新の実行を開き、
route_complaintタスクが deferred 状態になるまで待ちます。 - Required Actions タブで Billing Issue を選択し、回答を送信します。
- Graph ビューに切り替え、各タスクの状態を確認します。
"Billing Issue" を選択した後、選択しなかったタスクはどうなりますか?
この演習はコースの一部です
