Ветвление с HITLBranchOperator

Пайплайн маршрутизации обращений использует HITLBranchOperator, чтобы человек мог выбрать, какая команда обработает каждый тикет. DAG развёрнут — запустите выполнение, выберите ветку и посмотрите, как Airflow справится с остальным.

Выполните следующие шаги:

В представлении Dags активируйте complaint_router и запустите выполнение.
Откройте последний запуск и дождитесь, пока задача route_complaint перейдёт в состояние deferred.
На вкладке Required Actions выберите Billing Issue и отправьте ответ.
Перейдите в представление Graph и проверьте состояние каждой задачи.

Что произойдёт с задачами, которые вы не выбрали, после выбора «Billing Issue»?

Это упражнение является частью курса

Построение пайплайнов данных с Airflow

Посмотреть курс

Практическое интерактивное упражнение

Превратите теорию в практику с помощью одного из наших интерактивных упражнений

Начать упражнение