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 )