Menentukan Urutan Task
Sekarang setelah Anda mempelajari sintaks bitshift, saatnya menentukan urutan task. Saat ini Anda memiliki tiga task yang sudah didefinisikan, yaitu cleanup, consolidate, dan push_data.
Dekorator dag dan task dari airflow.sdk sudah diimpor.
Latihan ini merupakan bagian dari kursus
Pengantar Apache Airflow dengan Python
Instruksi latihan
- Konfigurasikan agar task
cleanupberjalan terlebih dahulu sebelum taskconsolidate, menggunakan sintaks bitshift. - Konfigurasikan
consolidateuntuk berjalan berikutnya dan taskpush_datauntuk berjalan terakhir.
Latihan interaktif langsung praktik
Cobalah latihan ini dengan melengkapi kode contoh ini.
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()