Definindo um SLA
Você implementou com sucesso vários workflows do Airflow em produção, mas atualmente não tem nenhum método para determinar se um workflow está levando tempo demais para rodar. Depois de consultar sua gerência e seu time, você decide implementar um SLA no nível do DAG em um workflow de teste.
Todas as bibliotecas apropriadas do Airflow já foram importadas para você.
Este exercício faz parte do curso
Introdução ao Apache Airflow em Python
Instruções do exercício
- Importe o objeto
timedelta. - Defina um
slade 30 minutos. - Adicione o SLA ao DAG.
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
# 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)