diff --git a/dags/sources/dags/source_aliapur.py b/dags/sources/dags/source_aliapur.py index 89b4d216c..e42d7b260 100755 --- a/dags/sources/dags/source_aliapur.py +++ b/dags/sources/dags/source_aliapur.py @@ -115,6 +115,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_citeo.py b/dags/sources/dags/source_citeo.py index 17608fa84..b83eb2d1f 100755 --- a/dags/sources/dags/source_citeo.py +++ b/dags/sources/dags/source_citeo.py @@ -105,6 +105,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_corepile.py b/dags/sources/dags/source_corepile.py index 21e5feef3..55fa38728 100755 --- a/dags/sources/dags/source_corepile.py +++ b/dags/sources/dags/source_corepile.py @@ -109,6 +109,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_cyclevia.py b/dags/sources/dags/source_cyclevia.py index aadde838d..d3cfa142c 100755 --- a/dags/sources/dags/source_cyclevia.py +++ b/dags/sources/dags/source_cyclevia.py @@ -138,6 +138,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_ecodds.py b/dags/sources/dags/source_ecodds.py index d02c0ec80..0cf3686b7 100755 --- a/dags/sources/dags/source_ecodds.py +++ b/dags/sources/dags/source_ecodds.py @@ -115,6 +115,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_ecologic.py b/dags/sources/dags/source_ecologic.py index b4a0d9642..b4280e5ee 100755 --- a/dags/sources/dags/source_ecologic.py +++ b/dags/sources/dags/source_ecologic.py @@ -105,6 +105,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_ecomaison.py b/dags/sources/dags/source_ecomaison.py index be1afecb3..966ab09e6 100755 --- a/dags/sources/dags/source_ecomaison.py +++ b/dags/sources/dags/source_ecomaison.py @@ -124,6 +124,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_ecopae.py b/dags/sources/dags/source_ecopae.py index 95914f36f..8efcfc310 100755 --- a/dags/sources/dags/source_ecopae.py +++ b/dags/sources/dags/source_ecopae.py @@ -114,6 +114,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_ecosystem.py b/dags/sources/dags/source_ecosystem.py index fa438259b..1ec510ef1 100755 --- a/dags/sources/dags/source_ecosystem.py +++ b/dags/sources/dags/source_ecosystem.py @@ -105,6 +105,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_ocab.py b/dags/sources/dags/source_ocab.py index e23f970fd..bb75e9577 100755 --- a/dags/sources/dags/source_ocab.py +++ b/dags/sources/dags/source_ocab.py @@ -109,6 +109,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_ocad3e.py b/dags/sources/dags/source_ocad3e.py index 367891773..982bb0df6 100755 --- a/dags/sources/dags/source_ocad3e.py +++ b/dags/sources/dags/source_ocad3e.py @@ -120,6 +120,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_pharmacies.py b/dags/sources/dags/source_pharmacies.py index 6ca5ced72..87e272f0c 100755 --- a/dags/sources/dags/source_pharmacies.py +++ b/dags/sources/dags/source_pharmacies.py @@ -93,6 +93,11 @@ "transformation": "clean_identifiant_unique", "destination": ["identifiant_unique"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "Téléphone"}, {"remove": "Région"}, diff --git a/dags/sources/dags/source_pyreo.py b/dags/sources/dags/source_pyreo.py index f87eff16a..ef96a4cc8 100755 --- a/dags/sources/dags/source_pyreo.py +++ b/dags/sources/dags/source_pyreo.py @@ -139,6 +139,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_refashion.py b/dags/sources/dags/source_refashion.py index ce5ddc54b..e1333bbf7 100755 --- a/dags/sources/dags/source_refashion.py +++ b/dags/sources/dags/source_refashion.py @@ -139,6 +139,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_screlec.py b/dags/sources/dags/source_screlec.py index 4b7ddf7d0..5469cbe8b 100644 --- a/dags/sources/dags/source_screlec.py +++ b/dags/sources/dags/source_screlec.py @@ -130,6 +130,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_sinoe.py b/dags/sources/dags/source_sinoe.py index b3a117c25..1ac2a0dd4 100755 --- a/dags/sources/dags/source_sinoe.py +++ b/dags/sources/dags/source_sinoe.py @@ -107,6 +107,11 @@ "transformation": "clean_identifiant_unique", "destination": ["identifiant_unique"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_geopoint"}, {"remove": "_i"}, diff --git a/dags/sources/dags/source_soren.py b/dags/sources/dags/source_soren.py index 9c4998e87..9d303b336 100755 --- a/dags/sources/dags/source_soren.py +++ b/dags/sources/dags/source_soren.py @@ -121,6 +121,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"}, diff --git a/dags/sources/dags/source_valdelia.py b/dags/sources/dags/source_valdelia.py index afd37f36e..ab14754b5 100755 --- a/dags/sources/dags/source_valdelia.py +++ b/dags/sources/dags/source_valdelia.py @@ -130,6 +130,11 @@ "transformation": "clean_action_codes", "destination": ["action_codes"], }, + { + "origin": ["action_codes", "souscategorie_codes"], + "transformation": "clean_proposition_services", + "destination": ["proposition_services_codes"], + }, # 5. Supression des colonnes {"remove": "_i"}, {"remove": "_id"},