Mendefinisikan SLA tugas
Setelah menyelesaikan SLA pada seluruh alur kerja, Anda menyadari bahwa Anda sebenarnya hanya memerlukan penentuan waktu SLA pada satu tugas tertentu, bukan pada keseluruhan alur kerja.
Pustaka Airflow yang diperlukan telah diimpor untuk Anda.
Latihan ini adalah bagian dari kursus
Pengantar Apache Airflow dengan Python
Petunjuk latihan
- Impor objek
timedelta. - Tambahkan
slaselama 3 jam ke tugas tersebut.
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
# Import the timedelta object
____
test_dag = DAG('test_workflow', start_date=datetime(2024,1,20), schedule_interval=None)
# Create the task with the SLA
task1 = BashOperator(task_id='first_task',
____=____,
bash_command='initialize_data.sh',
dag=test_dag)