diff --git a/integrations/valkey/src/haystack_integrations/document_stores/valkey/document_store.py b/integrations/valkey/src/haystack_integrations/document_stores/valkey/document_store.py index f911d06cd8..8742ade065 100644 --- a/integrations/valkey/src/haystack_integrations/document_stores/valkey/document_store.py +++ b/integrations/valkey/src/haystack_integrations/document_stores/valkey/document_store.py @@ -224,6 +224,7 @@ def _get_connection(self) -> SyncGlideClient | SyncGlideClusterClient: addresses=addresses, use_tls=self._use_tls, credentials=self._build_credentials(self._username, self._password), + client_name="haystack_vector_store_client", request_timeout=self._request_timeout, reconnect_strategy=reconnect_strategy, ) @@ -233,9 +234,9 @@ def _get_connection(self) -> SyncGlideClient | SyncGlideClusterClient: addresses=addresses, use_tls=self._use_tls, credentials=self._build_credentials(self._username, self._password), + client_name="haystack_vector_store_client", request_timeout=self._request_timeout, reconnect_strategy=reconnect_strategy, - client_name="haystack_vector_store_client", ) self._client = SyncGlideClient.create(client_config) return self._client @@ -262,6 +263,7 @@ async def _get_connection_async(self) -> GlideClient | GlideClusterClient: addresses=addresses, use_tls=self._use_tls, credentials=self._build_credentials(self._username, self._password), + client_name="haystack_vector_store_client", request_timeout=self._request_timeout, reconnect_strategy=reconnect_strategy, ) @@ -271,9 +273,9 @@ async def _get_connection_async(self) -> GlideClient | GlideClusterClient: addresses=addresses, use_tls=self._use_tls, credentials=self._build_credentials(self._username, self._password), + client_name="haystack_vector_store_client", request_timeout=self._request_timeout, reconnect_strategy=reconnect_strategy, - client_name="haystack_vector_store_client", ) self._async_client = await GlideClient.create(client_config) return self._async_client