ComeçarComece de graça

Definindo um SLA de tarefa

Depois de concluir o SLA para todo o workflow, você percebe que só precisa do tempo de SLA em uma tarefa específica, em vez do workflow completo.

As bibliotecas apropriadas do Airflow já foram importadas para você.

Este exercício faz parte do curso

Introdução ao Apache Airflow em Python

Ver curso

Instruções do exercício

  • Importe o objeto timedelta.
  • Adicione um sla de 3 horas à tarefa.

Exercício interativo prático

Experimente este exercício completando este código de exemplo.

# Import the timedelta object
____

test_dag = DAG('test_workflow', start_date=datetime(2024,1,20), schedule_interval=None)

# Create the task with the SLA
task1 = BashOperator(task_id='first_task',
                     ____=____,
                     bash_command='initialize_data.sh',
                     dag=test_dag)
Editar e executar o código