diff --git a/airflow/dags/import_EOSC_graph.py b/airflow/dags/import_EOSC_graph.py
index 7d47d57..b47a0cd 100644
--- a/airflow/dags/import_EOSC_graph.py
+++ b/airflow/dags/import_EOSC_graph.py
@@ -181,7 +181,7 @@ def import_EOSC_graph():
         conn = BaseHook.get_connection('opensearch_default')
         client = OpenSearch(
             hosts=[{'host': conn.host, 'port': conn.port}],
-            http_auth=(OPENSEARCH_USER, OPENSEARCH_PASSWD),
+            http_auth=(conn.login, conn.password),
             use_ssl=True,
             verify_certs=False,
             ssl_show_warn=False,