Eine Task-SLA definieren

Nachdem du die SLA für den gesamten Workflow festgelegt hast, merkst du, dass du die SLA-Zeitvorgabe eigentlich nur für eine bestimmte Aufgabe brauchst – nicht für den ganzen Workflow.

Die passenden Airflow-Bibliotheken sind bereits für dich importiert.

Diese Übung ist Teil des Kurses

Einführung in Apache Airflow mit Python

Kurs anzeigen

Anleitung zur Übung

Importiere das Objekt timedelta.
Füge der Aufgabe eine sla von 3 Stunden hinzu.

Interaktive Übung

Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.

# 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 bearbeiten und ausführen