Ajout de max_active_runs pour ne pas lancer plusieurs execution du mê…

…me dag

dags/compute_acteurs/dags/create_final_actors.py

@@ -39,6 +39,7 @@
         " plusieurs sources en cumulant leur services, sources et propositions"
         " services."
     ),
+    max_active_runs=1,
     schedule=None,
 )
 

dags/sources/dags/source_aliapur.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Aliapur dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_citeo.py

@@ -11,6 +11,7 @@
         "Injestion des données de l'éco-organisme CITEO à partir des données disponible"
         " sur de Koumoul"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_cma.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for CMA reparacteur dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_corepile.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Corepile dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_cyclevia.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Pyreo dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_ecodds.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for EcoDDS dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_ecologic.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Ecologic dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_ecomaison.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Ecomaison dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_ecopae.py

@@ -11,6 +11,7 @@
         "Injestion des données de l'éco-organisme ECOPAE à partir des données"
         " disponibles sur Koumoul"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_ecosystem.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Ecosystem dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_ocab.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for OCAB dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_ocad3e.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for OCAD3E dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_pharmacies.py

@@ -8,6 +8,7 @@
     dag_display_name="Source - PHARMACIES",
     default_args=default_args,
     description=("Téléchargement des pharmacies (Ordre National Des Pharmaciens)"),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_pyreo.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Pyreo dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_refashion.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Refashion dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_screlec.py

@@ -12,6 +12,7 @@
         " disponibles sur de Koumoul"
     ),
     tags=["source", "ademe", "screlec", "piles", "batteries", "accumulateurs"],
+    max_active_runs=1,
     params={
         "endpoint": (
             "https://data.ademe.fr/data-fair/api/v1/datasets/"

dags/sources/dags/source_sinoe.py

@@ -14,6 +14,7 @@
         "DAG pour télécharger, standardiser, et charger dans notre base la source SINOE"
     ),
     tags=["source", "ademe", "sinoe", "déchèteries"],
+    max_active_runs=1,
     params={
         "endpoint": (
             "https://data.ademe.fr/data-fair/api/v1/datasets/"

dags/sources/dags/source_soren.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Soren dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes

dags/sources/dags/source_valdelia.py

@@ -11,6 +11,7 @@
         "A pipeline to fetch, process, and load to validate data into postgresql"
         " for Valdelia dataset"
     ),
+    max_active_runs=1,
     params={
         "normalization_rules": [
             # 1. Renommage des colonnes