Definieren einer Aufgabe SLA

Nachdem du die SLA für den gesamten Arbeitsablauf fertiggestellt hast, stellst du fest, dass du das SLA Timing wirklich nur für eine bestimmte Aufgabe brauchst und nicht für den gesamten Arbeitsablauf.

Die entsprechenden Airflow-Bibliotheken werden für dich importiert.

Diese Übung ist Teil des Kurses

Einführung in Apache Airflow in Python

Kurs anzeigen

Anleitung zur Übung

Importiere das Objekt timedelta.
Füge der Aufgabe eine 3-stündige sla 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