chore(pipeline): clean up settings

gip-inclusion · Dec 8, 2023 · 7af2569 · 7af2569
1 parent 30e377a
commit 7af2569
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/pipeline/dags/import_sources.py b/pipeline/dags/import_sources.py
@@ -63,6 +63,7 @@ def _extract(
         mes_aides,
         reseau_alpha,
         soliguide,
+        un_jeune_une_solution,
         utils,
     )
 
@@ -81,7 +82,7 @@ def _extract(
         "finess": utils.extract_http_content,
         "mes-aides": mes_aides.extract,
         "siao": utils.extract_http_content,
-        "un-jeune-une-solution": utils.extract_http_content,
+        "un-jeune-une-solution": un_jeune_une_solution.extract,
         "soliguide": soliguide.extract,
         "monenfant": utils.extract_http_content,
         "reseau-alpha": {

diff --git a/pipeline/src/data_inclusion/scripts/tasks/un_jeune_une_solution.py b/pipeline/src/data_inclusion/scripts/tasks/un_jeune_une_solution.py
@@ -0,0 +1,5 @@
+from data_inclusion.scripts.tasks import utils
+
+
+def extract(id: str, url: str, **kwargs) -> bytes:
+    return utils.extract_http_content(url.rstrip("/") + "/" + id)