From 37ef1c76ee0472d2673e2993f82c6d932aafa490 Mon Sep 17 00:00:00 2001 From: S-P Chan Date: Tue, 14 Oct 2025 07:59:23 +0800 Subject: [PATCH] get_distributed_object: skip unsupported proxies - currently hz:impl:cacheService is not supported --- hazelcast/client.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/hazelcast/client.py b/hazelcast/client.py index 39a38dcec6..2962b31732 100644 --- a/hazelcast/client.py +++ b/hazelcast/client.py @@ -49,6 +49,7 @@ Ringbuffer, Set, Topic, + _proxy_init, ) from hazelcast.proxy.base import Proxy from hazelcast.proxy.map import Map @@ -67,6 +68,8 @@ _logger = logging.getLogger(__name__) +_SUPPORTED_DDS_NAMES = set(_proxy_init.keys()) + class HazelcastClient: """Hazelcast client instance to access and manipulate distributed data @@ -495,8 +498,13 @@ def get_distributed_objects(self) -> typing.List[Proxy]: } response = client_get_distributed_objects_codec.decode_response(invocation.future.result()) + for dist_obj_info in response: local_distributed_object_infos.discard(dist_obj_info) + + # skip unsupported proxies, e.g., hz:impl:cacheService + if dist_obj_info.service_name not in _SUPPORTED_DDS_NAMES: + continue self._proxy_manager.get_or_create( dist_obj_info.service_name, dist_obj_info.name, create_on_remote=False )