Definição de uma tarefa SLA

Depois de concluir o SLA em todo o fluxo de trabalho, você percebe que realmente só precisa do SLA timing em uma tarefa específica, em vez de no fluxo de trabalho completo.

As bibliotecas apropriadas do Airflow são importadas para você.

Este exercício faz parte do curso

Introdução ao Apache Airflow em Python

Ver Curso

Instruções de exercício

Importe o objeto timedelta.
Adicione um período de 3 horas sla à tarefa.

Exercício interativo prático

Experimente este exercício preenchendo 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 código