initial stage

2024-03-25 16:05:34 +01:00 · 2024-03-25 16:05:34 +01:00 · c07ddc03d9
parent 0c27895e13
commit c07ddc03d9
2 changed files with 4 additions and 1 deletions
--- a/airflow/dags/import_EOSC_graph.py
+++ b/airflow/dags/import_EOSC_graph.py
@ -66,7 +66,7 @@ def map_access_right(ar: str) -> str:

 def map_product(p: dict) -> dict:
    p['accessRight'] = list(
-        filter(lambda ar: ar != '', map(lambda m: map_access_right(m.get('access_rights')), p.get('manifestations'))))
+        filter(lambda ar: ar != '', map(lambda m: map_access_right(m.get('access_right')), p.get('manifestations'))))
    return p


--- a/airflow/dags/opensearch_indexes.py
+++ b/airflow/dags/opensearch_indexes.py
@ -334,6 +334,9 @@ mappings['products'] = {
                }
            }
        },
+        "accessRight": {
+            "type": "keyword"
+        },
        "contributions": {
            "type": "object",
            "properties": {