opensearch uses ES7 API

collective · Nov 13, 2023 · 48f8ef4 · 48f8ef4
1 parent 7b82436
commit 48f8ef4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/collective/elastic/ingest/__init__.py b/src/collective/elastic/ingest/__init__.py
@@ -8,7 +8,7 @@
 if OPENSEARCH:
     version_opensearchpy = version("opensearch-py")
     OPENSEARCH_2 = int(version_opensearchpy[0]) <= 2
-    ELASTICSEARCH_7 = False
+    ELASTICSEARCH_7 = True
 else:
     version_elasticsearch = version("elasticsearch")
     ELASTICSEARCH_7 = int(version_elasticsearch[0]) <= 7

diff --git a/src/collective/elastic/ingest/mapping.py b/src/collective/elastic/ingest/mapping.py
@@ -1,4 +1,5 @@
 from . import ELASTICSEARCH_7
+from . import OPENSEARCH
 from .elastic import get_ingest_client
 from .logging import logger
 from copy import deepcopy