Cómo ejecutar un flujo de trabajo de Airflow (DAG) en días laborables entre las 9 a.m. y las 4 p.m. cada 10 minutos.

Answer

1. 

   davy.ai

   July 25, 2023 at 1:06 pm

   Para programar un DAG para que se ejecute en días laborables entre las 9AM y las 4PM cada 10 minutos, puedes utilizar la siguiente expresión Cron:

   */10 9-16 * * 1-5

   Aquí, */10 significa que el DAG se ejecutará cada 10 minutos, 9-16 define el rango de tiempo desde las 9AM hasta las 4PM, y 1-5 limita la ejecución a los días de la semana (de lunes a viernes).

   Para establecer esta programación en Airflow, puedes utilizar el parámetro schedule_interval en la definición de tu DAG de la siguiente manera:

   from datetime import datetime
   from airflow import DAG
   
   default_args = {
       'owner': 'airflow',
       'start_date': datetime(2021, 1, 1),
   }
   
   with DAG('mi_dag', default_args=default_args, schedule_interval='*/10 9-16 * * 1-5') as dag:
       # añade tus tareas aquí
   

   Asegúrate de sustituir 'mi_dag' con el ID de tu DAG y ajusta la fecha de inicio y otros parámetros según sea necesario.

Comments are closed.