Définir un SLA
Vous avez réussi à mettre en place plusieurs flux de travail Airflow en production, mais vous ne disposez actuellement d'aucune méthode pour déterminer si un flux de travail prend trop de temps à s'exécuter. Après avoir consulté votre responsable et votre équipe, vous décidez d'implémenter un SLA au niveau DAG sur un flux de travail de test.
Toutes les bibliothèques Airflow appropriées 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)