Revert "dont wait for indexes to be ready"

This reverts commit 8ea5dfe.
opensanctions · Jul 15, 2024 · c138ea1 · c138ea1
1 parent 8ea5dfe
commit c138ea1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/yente/provider/elastic.py b/yente/provider/elastic.py
@@ -45,8 +45,8 @@ async def create(cls) -> "ElasticSearchProvider":
         for retry in range(2, 9):
             try:
                 es = AsyncElasticsearch(**kwargs)
-                # es_ = es.options(request_timeout=15)
-                # await es_.cluster.health(wait_for_status="yellow")
+                es_ = es.options(request_timeout=15)
+                await es_.cluster.health(wait_for_status="yellow")
                 return ElasticSearchProvider(es)
             except (TransportError, ConnectionError) as exc:
                 log.error("Cannot connect to ElasticSearch: %r" % exc)

diff --git a/yente/provider/opensearch.py b/yente/provider/opensearch.py
@@ -40,7 +40,7 @@ async def create(cls) -> "OpenSearchProvider":
         for retry in range(2, 9):
             try:
                 es = AsyncOpenSearch(**kwargs)
-                # await es.cluster.health(wait_for_status="yellow")
+                await es.cluster.health(wait_for_status="yellow")
                 return OpenSearchProvider(es)
             except (TransportError, ConnectionError) as exc:
                 log.error("Cannot connect to OpenSearch: %r" % exc)