diff --git a/airflow/dags/import_EOSC_graph.py b/airflow/dags/import_EOSC_graph.py
index efaacb2..8cd36a8 100644
--- 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
 
 
diff --git a/airflow/dags/opensearch_indexes.py b/airflow/dags/opensearch_indexes.py
index cbfcf4b..808141a 100644
--- 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": {