İnsan döngülü (HITL) iş akışları

Airflow ile Veri İş Hatları Oluşturma

Volker Janz

Senior Developer Advocate at Astronomer

HITL kullanım alanları

Yapay zekâ yanıtını onaylama
Destek talebini doğru ekibe yönlendirme
Yayınlamadan önce veri kalitesi raporunu gözden geçirme

İnsan döngüde görseli

HITL operatör ailesi

Operatör	Kullanım alanı
`ApprovalOperator`	İkili onayla/reddet
`HITLBranchOperator`	Sonraki hangi görevler çalışacak seç
`HITLOperator`	Özelleştirilmiş seçenekler + form
`HITLEntryOperator`	Sadece form girişi, seçenek yok

Tüm HITL operatörleri ertelenebilir operatör olarak uygulanır

HITLEntryOperator

from airflow.providers.standard.operators.hitl import HITLEntryOperator
from airflow.sdk import Param


review = HITLEntryOperator(
    task_id="human_review",
    subject="Review AI draft response",
    body="{{ ti.xcom_pull(task_ids='generate_draft') }}",
    params={
        "feedback": Param("", type="string"),
        "urgency": Param("p3", type="string"),
    },
)

Form alanları doldurulana kadar boru hattı durur

Yanıta erişim

@task
def send_response(hitl_output):
    feedback = hitl_output["params_input"]["feedback"]
    urgency = hitl_output["params_input"]["urgency"]
    print(f"Sending response (urgency: {urgency}): {feedback}")


draft = generate_draft()
chain(draft, review)
send_response(review.output)

Form girdileri params_input içinde
Seçenekler (varsa) chosen_options içinde

HITLBranchOperator

from airflow.providers.standard.operators.hitl import HITLBranchOperator


route = HITLBranchOperator(
    task_id="route_complaint",
    subject="Route customer complaint",
    body="A customer reported an issue. Choose the responsible team.",
    options=["Billing Issue", "General Inquiry", "Technical Issue"],
    options_mapping={
        "Billing Issue": "handle_billing",
        "Technical Issue": "handle_technical",
        "General Inquiry": "handle_general",
    },
    defaults=["General Inquiry"],
)

İnsan bir seçenek seçer, bu seçim bir alt görev kimliğine eşlenir
Seçilmeyen yollar atlanır

UI'da Gerekli İşlemler

HITL görevleri bir Gerekli İşlem oluşturur
İnceleyiciler görev örneği görünümünde yanıtlar

Tüm HITL operatörleri ertelenebilir
Beklerken worker yuvasını boş bırakırlar
Triggerer eşzamansız beklemeyi yönetir

Airflow UI'da HITL

Hadi pratik yapalım!

Airflow ile Veri İş Hatları Oluşturma