Definir un SLA de tarea

Después de establecer el SLA para todo el flujo de trabajo, te das cuenta de que realmente solo necesitas el tiempo de SLA en una tarea específica en lugar de en todo el flujo.

Ya tienes importadas las bibliotecas adecuadas de Airflow.

Este ejercicio forma parte del curso

Introducción a Apache Airflow en Python

Ver curso

Instrucciones del ejercicio

Importa el objeto timedelta.
Añade un sla de 3 horas a la tarea.

Ejercicio interactivo práctico

Prueba este ejercicio y completa el código de muestra.

# 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 y ejecutar código