Een taak-SLA definiëren

Na het instellen van de SLA voor de hele workflow, realiseer je je dat je de SLA-timing eigenlijk alleen voor een specifieke taak nodig hebt in plaats van voor de volledige workflow.

De juiste Airflow-bibliotheken zijn al voor je geïmporteerd.

Deze oefening maakt deel uit van de cursus

Introductie tot Apache Airflow in Python

Cursus bekijken

Oefeninstructies

Importeer het object timedelta.
Voeg een sla van 3 uur toe aan de taak.

Praktische interactieve oefening

Probeer deze oefening eens door deze voorbeeldcode in te vullen.

# 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)

Code bewerken en uitvoeren