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 de ejercicio

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

Ejercicio interactivo práctico

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