Добавление шага ручного согласования
Во время работы над рабочим процессом руководитель сообщает вам о проблемах с данными, которые публикуются в аналитической базе данных отдела продаж. Он хочет убедиться, что данные по продажам выглядят корректно, прежде чем они попадут в хранилище данных. Вы понимаете, что шаг ручного согласования (HITL Approval) — хороший способ добавить финальную проверку перед вставкой данных.
Объекты dag, task и timedelta уже импортированы за вас.
Это упражнение является частью курса
Введение в Apache Airflow на Python
Инструкции к упражнению
- Импортируйте нужную библиотеку для создания задачи подтверждения или отклонения (Approve / Reject).
- Создайте задачу согласования
approve_gate. - Задайте заголовок запроса на согласование, который будет отображаться проверяющему в интерфейсе Airflow.
Интерактивное практическое упражнение
Попробуйте выполнить это упражнение, дополнив этот пример кода.
# Import ApprovalOperator
from airflow.providers.standard.operators.____ import ____
@dag(start_date=datetime(2026,4,15))
def data_warehouse_dag():
# Create the approve_gate approval task
approve_gate = ____(
task_id="approve_sales_data",
# Set the title for the approval request shown to the reviewer
____="Sales data processing - Approval Required",
body=(
"Please review the sales data produced by the *pull_raw_data* task."
"Approve to push leads to the data warehouse, or Reject to halt the run."
),
)
pull_raw_data() >> approve_gate >> push_to_warehouse()
data_warehouse_dag()