File tree Expand file tree Collapse file tree 1 file changed +7
-0
lines changed
Expand file tree Collapse file tree 1 file changed +7
-0
lines changed Original file line number Diff line number Diff line change 4949 Ringbuffer ,
5050 Set ,
5151 Topic ,
52+ _proxy_init ,
5253)
5354from hazelcast .proxy .base import Proxy
5455from hazelcast .proxy .map import Map
6768
6869_logger = logging .getLogger (__name__ )
6970
71+ _SUPPORTED_DDS_NAMES = set (_proxy_init .keys ())
7072
7173class HazelcastClient :
7274 """Hazelcast client instance to access and manipulate distributed data
@@ -495,8 +497,13 @@ def get_distributed_objects(self) -> typing.List[Proxy]:
495497 }
496498
497499 response = client_get_distributed_objects_codec .decode_response (invocation .future .result ())
500+
498501 for dist_obj_info in response :
499502 local_distributed_object_infos .discard (dist_obj_info )
503+
504+ # skip unsupported proxies, e.g., hz:impl:cacheService
505+ if dist_obj_info .service_name not in _SUPPORTED_DDS_NAMES :
506+ continue
500507 self ._proxy_manager .get_or_create (
501508 dist_obj_info .service_name , dist_obj_info .name , create_on_remote = False
502509 )
You can’t perform that action at this time.
0 commit comments