diff --git a/ray_elasticsearch/__init__.py b/ray_elasticsearch/__init__.py
index c8b1d93..6c54dcf 100644
--- a/ray_elasticsearch/__init__.py
+++ b/ray_elasticsearch/__init__.py
@@ -64,7 +64,7 @@ def __init__(
         self._chunk_size = chunk_size
         self._client_kwargs = client_kwargs
 
-    @cached_property
+    @property
     def _elasticsearch(self) -> Elasticsearch:
         return Elasticsearch(**self._client_kwargs)