Menambahkan persetujuan manusia
Saat mengerjakan sebuah workflow, atasan Anda menyebutkan bahwa ada masalah dengan data yang diposting ke database analitik tim penjualan. Mereka ingin memastikan bahwa data penjualan sudah benar sebelum diposting ke gudang data. Anda menyadari bahwa langkah persetujuan HITL merupakan opsi yang baik untuk menambahkan pemeriksaan terakhir sebelum penyisipan data.
Objek dag, task, dan timedelta semuanya sudah diimpor untuk Anda.
Latihan ini adalah bagian dari kursus
Pengantar Apache Airflow dengan Python
Petunjuk latihan
- Impor pustaka yang sesuai untuk membuat tugas Approve / Reject.
- Buat tugas persetujuan
approve_gate. - Tetapkan judul untuk permintaan persetujuan yang akan muncul kepada peninjau di UI Airflow.
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
# 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()