Update 07-08-23. Update schedule from DAG's

dags/dag_inform_process.py

@@ -20,7 +20,7 @@ logger = logging.getLogger()
 DAG_NAME = "INFORM_PROCESS"
 
 # Change this path if is deployed in prod or dev
-MAIN_PATH = "/root/airflow/dags/"
+MAIN_PATH = "/opt/airflow/dags/"
 
 DEFAULT_ARGS = {
     'owner': 'BCOM',
@@ -181,7 +181,7 @@ def set_dag():
         logger.info(f"CONFIGURACIÓN: {data}")
         conf = data["app"]
     with DAG(DAG_NAME, default_args=DEFAULT_ARGS, description="Proceso que informa del último proceso ejecutado",
-             schedule_interval=conf["inform_dag_schedule"], tags=["DAG BCOM - INFORM PROCESS"], catchup=True) as dag:
+             schedule_interval=conf["inform_dag_schedule"], tags=["DAG BCOM - INFORM PROCESS"], catchup=False) as dag:
         control_s3 = conf["control"]["s3_params"]
         timezone = conf["timezone"]
         control_extractor = PythonOperator(

dags/dag_reset_process.py

@@ -92,7 +92,7 @@ def set_dag():
         logger.info(f"CONFIGURACIÓN: {data}")
         conf = data["app"]
     with DAG(DAG_NAME, default_args=DEFAULT_ARGS, description="Proceso que resetea el último proceso ejecutado",
-             schedule_interval=conf["reset_dag_schedule"], tags=["DAG BCOM - RESET PROCESS"], catchup=True) as dag:
+             schedule_interval=conf["reset_dag_schedule"], tags=["DAG BCOM - RESET PROCESS"], catchup=False) as dag:
         control_s3 = conf["control"]["s3_params"]
         timezone = conf["timezone"]
         control_extractor = PythonOperator(

dags/dag_transformacion_bcom.py

@@ -25,7 +25,7 @@ logger = logging.getLogger()
 DAG_NAME = "BCOM_DAG_EXTRACT_AND_TRANSFORM"
 
 # Change this path if is deployed in prod or dev
-MAIN_PATH = "/root/airflow/dags/"
+MAIN_PATH = "/opt/airflow/dags/"
 
 DEFAULT_ARGS = {
     'owner': 'BCOM',
@@ -143,7 +143,7 @@ def set_dag():
         logger.info(f"CONFIGURACIÓN: {data}")
         conf = data["app"]
     with DAG(DAG_NAME, default_args=DEFAULT_ARGS, description="Proceso que extrae y transforma",
-             schedule_interval=conf["schedule"], tags=["DAG BCOM - SQL TRANSFORMATIONS"], catchup=True) as dag:
+             schedule_interval=conf["schedule"], tags=["DAG BCOM - SQL TRANSFORMATIONS"], catchup=False) as dag:
         scripts_s3 = conf["scripts"]["s3_params"]
         if scripts_s3["prefix"].endswith("/"):
             wildcard_scripts = scripts_s3["prefix"] + "?*"