Définir un SLA
Vous avez mis en production plusieurs workflows Airflow avec succès, mais vous n’avez actuellement aucun moyen de savoir si un workflow met trop de temps à s’exécuter. Après avoir échangé avec votre manager et votre équipe, vous décidez de mettre en place un SLA au niveau du DAG sur un workflow de test.
Toutes les bibliothèques Airflow nécessaires ont été importées pour vous.
Cet exercice fait partie du cours
Introduction à Apache Airflow en Python
Instructions
- Importez l’objet
timedelta. - Définissez un
slade 30 minutes. - Ajoutez le SLA au DAG.
Exercice interactif pratique
Essayez cet exercice en complétant cet exemple de code.
# 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)