İnsan onayı ekleme

Bir iş akışı üzerinde çalışırken, patronun satış ekibinin analitik veritabanına gönderilen verilerle ilgili sorunlar olduğunu söylüyor. Satış verileri bir veri ambarına yüklenmeden önce iyi göründüğünden emin olmak istiyorlar. Sen de, veri eklemeden hemen önce son bir kontrol adımı olarak bir HITL Onay adımı eklemenin iyi bir seçenek olduğunu fark ediyorsun.

dag, task ve timedelta nesnelerinin tümü senin için içe aktarıldı.

Bu egzersiz, kursun bir parçasıdır

Python ile Apache Airflow’a Giriş

Kursa Göz Atın

Egzersiz talimatları

Onayla / Reddet görevi oluşturmak için uygun kütüphaneyi içe aktar.
approve_gate onay görevini oluştur.
Airflow UI'da gözden geçirene görünecek onay isteği başlığını ayarla.

Uygulamalı etkileşimli egzersiz

Bu egzersizi bu örnek kodu tamamlayarak deneyin.

# 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()

Kodu Düzenle ve Çalıştır