Update ns_topology and multivim_vm_status DAGs to disable overlapped execution 50/13150/1
authorgarciadeblas <gerardo.garciadeblas@telefonica.com>
Wed, 5 Apr 2023 09:10:32 +0000 (11:10 +0200)
committergarciadeblas <gerardo.garciadeblas@telefonica.com>
Wed, 5 Apr 2023 09:10:57 +0000 (11:10 +0200)
Change-Id: Idbfa27879a3604e45cf4c92270c4c86de48bca93
Signed-off-by: garciadeblas <gerardo.garciadeblas@telefonica.com>
src/osm_ngsa/dags/multivim_vm_status.py
src/osm_ngsa/dags/ns_topology.py

index 3cedabc..454f384 100644 (file)
@@ -70,6 +70,7 @@ def create_dag(dag_id, dag_number, dag_description, vim_id):
         },
         description=dag_description,
         is_paused_upon_creation=False,
+        max_active_runs=1,
         # schedule_interval=timedelta(minutes=SCHEDULE_INTERVAL),
         schedule_interval=f"*/{SCHEDULE_INTERVAL} * * * *",
         start_date=datetime(2022, 1, 1),
index 0fc20c3..7d2af07 100644 (file)
@@ -42,6 +42,7 @@ logger = logging.getLogger("airflow.task")
     },
     description="NS topology",
     is_paused_upon_creation=False,
+    max_active_runs=1,
     # schedule_interval=timedelta(minutes=SCHEDULE_INTERVAL),
     schedule_interval=f"*/{SCHEDULE_INTERVAL} * * * *",
     start_date=datetime(2022, 1, 1),