Definir una tarea SLA

Después de completar el SLA en todo el flujo de trabajo, te das cuenta de que en realidad sólo necesitas el SLA cronometrado en una tarea específica en lugar del flujo de trabajo completo.

Se importarán por ti las bibliotecas Airflow adecuadas.

Este ejercicio forma parte del curso

Introducción a Apache Airflow en Python

Ver curso

Instrucciones del ejercicio

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

Ejercicio interactivo práctico

Prueba este ejercicio completando 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