diff --git a/libs/community/langchain_community/vectorstores/opensearch_vector_search.py b/libs/community/langchain_community/vectorstores/opensearch_vector_search.py index 795ae7271..d19dd771e 100644 --- a/libs/community/langchain_community/vectorstores/opensearch_vector_search.py +++ b/libs/community/langchain_community/vectorstores/opensearch_vector_search.py @@ -1302,9 +1302,15 @@ def _raw_similarity_search_with_score_by_vector( # hybrid search without post filter payload = _default_hybrid_search_query(query_text, embeded_query, k) - response = self.client.transport.perform_request( - method="GET", url=path, body=payload - ) + request_args: Dict[str, Any] = { + "method": "GET", + "url": path, + "body": payload, + } + if self.routing: + request_args["params"] = {"routing": self.routing} + + response = self.client.transport.perform_request(**request_args) return [hit for hit in response["hits"]["hits"]]