Skip to content

Commit

Permalink
elasticsearch[patch]: fix integration tests for release (#18980)
Browse files Browse the repository at this point in the history
  • Loading branch information
efriis authored and hinthornw committed Apr 26, 2024
1 parent aa50a2d commit 4d9e26f
Showing 1 changed file with 10 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
"""Test ElasticsearchRetriever functionality."""

import os
import re
import uuid
from typing import Any, Dict
Expand Down Expand Up @@ -77,11 +78,19 @@ def test_init_url(self, index_name: str) -> None:
def body_func(query: str) -> Dict:
return {"query": {"match": {text_field: {"query": query}}}}

es_url = os.environ.get("ES_URL", "http://localhost:9200")
cloud_id = os.environ.get("ES_CLOUD_ID")
api_key = os.environ.get("ES_API_KEY")

config = (
{"cloud_id": cloud_id, "api_key": api_key} if cloud_id else {"url": es_url}
)

retriever = ElasticsearchRetriever.from_es_params(
url="http://localhost:9200",
index_name=index_name,
body_func=body_func,
content_field=text_field,
**config, # type: ignore[arg-type]
)

index_test_data(retriever.es_client, index_name, text_field)
Expand Down

0 comments on commit 4d9e26f

Please sign in to comment.