Definire uno SLA
Hai implementato con successo diversi workflow di Airflow in produzione, ma al momento non hai alcun metodo per capire se un workflow impiega troppo tempo a eseguire. Dopo aver consultato il tuo manager e il tuo team, decidi di implementare uno SLA a livello di DAG su un workflow di test.
Tutte le librerie appropriate di Airflow sono già state importate per te.
Questo esercizio fa parte del corso
Introduzione ad Apache Airflow in Python
Istruzioni dell'esercizio
- Importa l'oggetto
timedelta. - Definisci uno
sladi 30 minuti. - Aggiungi lo SLA al DAG.
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
# Import the timedelta object
____
# Create the dictionary entry
default_args = {
'start_date': datetime(2024, 1, 20),
'____': ____
}
# Add to the DAG
test_dag = DAG('test_workflow', default_args=____, schedule_interval=None)