initial stage

2024-03-25 22:08:17 +01:00 · 2024-03-25 22:08:17 +01:00 · c9f23d2796
parent 8594587ee5
commit c9f23d2796
1 changed files with 1 additions and 1 deletions
--- 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,