Definição de um SLA
Você implementou com sucesso vários fluxos de trabalho do Airflow na produção, mas atualmente não tem nenhum método para determinar se um fluxo de trabalho leva muito tempo para ser executado. Após consultar o seu gerente e a sua equipe, você decide implementar um SLA no nível DAG em um fluxo de trabalho de teste.
Todas as bibliotecas Airflow apropriadas 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)