Menetapkan urutan eksekusi pipeline
Setelah membangun DAG Anda, sekarang saatnya menentukan urutan eksekusi untuk tugas-tugas dalam DAG.
Pada latihan sebelumnya, Anda telah menyiapkan tugas pertama untuk memeriksa API. Semua tugas lain dari pipeline telah disiapkan untuk Anda.
Anda perlu mengikuti urutan tugas dari diagram berikut.
Latihan ini adalah bagian dari kursus
Merancang Pipeline Peramalan untuk Produksi
Petunjuk latihan
- Atur tugas pipeline pemeriksaan API dan pemeriksaan status.
- Atur tugas-tugas pipeline validasi data.
- Atur tugas-tugas pipeline peramalan.
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
# Set the API check pipeline tasks
____ >> ____ >> [data_refresh, no_updates]
data_refresh >> [data_validation, data_failure]
# Set the data validation pipeline tasks
data_validation >> check_validation >> [____, ____]
# Set the forecast pipeline tasks
data_valid >> ____ >> ____
print(f"DAG '{dag.dag_id}' ready with {len(dag.tasks)} tasks")