Memicu Dag anak
Anda menyadari beberapa alur kerja menggunakan komponen serupa dan menyimpulkan bahwa Anda dapat memisahkan tugas umum ke Dag tersendiri. Ini memungkinkan Anda menjalankan komponen tersebut sesuai kebutuhan tanpa memelihara banyak salinan. Anda memutuskan untuk mengeksekusi Dag anak melalui sebuah task di dalam alur kerja saat ini.
Komponen dag, task, dan datetime telah diimpor untuk Anda.
Latihan ini merupakan bagian dari kursus
Pengantar Apache Airflow dengan Python
Instruksi latihan
- Impor operator yang diperlukan untuk memulai Dag dari dalam alur kerja Anda.
- Atur operator untuk memicu Dag bernama
child_pipeline. - Pastikan Dag induk menunggu Dag yang dipicu selesai sebelum melanjutkan.
- Atur seberapa sering operator memeriksa apakah Dag anak sudah selesai.
Latihan interaktif langsung praktik
Cobalah latihan ini dengan melengkapi kode contoh ini.
# Import TriggerDagRunOperator
from airflow.providers.standard.operators.trigger_dagrun import ____
@dag(start_date=datetime(2026, 1, 1))
def parent_orchestrator_dag():
# Trigger child_pipeline and wait for it to complete
trigger_child = TriggerDagRunOperator(
task_id="trigger_child_pipeline",
trigger_dag_id="____",
____=True,
____=30,
conf={"source": "s3://my-bucket/raw/"})
validate() >> trigger_child >> post_trigger_summary()
parent_orchestrator_dag()