giambattista.bloisi
/
lot1-kickoff
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

initial stage

This commit is contained in:
Giambattista Bloisi 2024-07-10 22:06:27 +02:00
parent 227ec44a21
commit eccf5d396c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
airflow/dags/import_Catalogues.py
View File

@ -94,11 +94,11 @@ def import_catalogue_entities():
for entity in kwargs["params"]["ENTITIES"]: for entity in kwargs["params"]["ENTITIES"]:
indexname = f'{entity}_{kwargs["params"]["SUFFIX"]}' indexname = f'{entity}_{kwargs["params"]["SUFFIX"]}'
baseurl = "http://vereniki.athenarc.gr:8080/eic-registry" 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"} params = {"draft": "false", "active": "true", "suspended": "false"}
while True: while True:
reply = session.get(url=baseurl, params=params) reply = session.get(url=callurl, params=params)
reply.raise_for_status() reply.raise_for_status()
content = reply.json() content = reply.json()
if 'results' not in content: if 'results' not in content: