From eccf5d396c954e16e50f1ed9e1dce4378d293a8f Mon Sep 17 00:00:00 2001 From: Giambattista Bloisi Date: Wed, 10 Jul 2024 22:06:27 +0200 Subject: [PATCH] initial stage --- airflow/dags/import_Catalogues.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/dags/import_Catalogues.py b/airflow/dags/import_Catalogues.py index 1736d2b..850c3fb 100644 --- a/airflow/dags/import_Catalogues.py +++ b/airflow/dags/import_Catalogues.py @@ -94,11 +94,11 @@ def import_catalogue_entities(): for entity in kwargs["params"]["ENTITIES"]: indexname = f'{entity}_{kwargs["params"]["SUFFIX"]}' baseurl = "http://vereniki.athenarc.gr:8080/eic-registry" - callurl = f"{baseurl}/{entity}?draft=false&active=true&suspended=false" + callurl = f"{baseurl}/{entity} params = {"draft": "false", "active": "true", "suspended": "false"} while True: - reply = session.get(url=baseurl, params=params) + reply = session.get(url=callurl, params=params) reply.raise_for_status() content = reply.json() if 'results' not in content: