get_distributed_object: skip unsupported proxies

- currently hz:impl:cacheService is not supported

Author: space88man

hazelcast/client.py

@@ -13,7 +13,11 @@
 from hazelcast.errors import IllegalStateError, InvalidConfigurationError
 from hazelcast.future import Future
 from hazelcast.invocation import InvocationService, Invocation
-from hazelcast.lifecycle import LifecycleService, LifecycleState, _InternalLifecycleService
+from hazelcast.lifecycle import (
+    LifecycleService,
+    LifecycleState,
+    _InternalLifecycleService,
+)
 from hazelcast.listener import ClusterViewListenerService, ListenerService
 from hazelcast.near_cache import NearCacheManager
 from hazelcast.partition import PartitionService, _InternalPartitionService
@@ -49,6 +53,7 @@
     Ringbuffer,
     Set,
     Topic,
+    _proxy_init,
 )
 from hazelcast.proxy.base import Proxy
 from hazelcast.proxy.map import Map
@@ -67,6 +72,8 @@
 
 _logger = logging.getLogger(__name__)
 
+_SUPPORTED_DDS_NAMES = set(_proxy_init.keys())
+
 
 class HazelcastClient:
     """Hazelcast client instance to access and manipulate distributed data
@@ -227,7 +234,9 @@ def _start(self):
             self._internal_lifecycle_service.start()
             self._invocation_service.start()
             membership_listeners = self._config.membership_listeners
-            self._internal_cluster_service.start(self._connection_manager, membership_listeners)
+            self._internal_cluster_service.start(
+                self._connection_manager, membership_listeners
+            )
             self._cluster_view_listener.start()
             self._connection_manager.start(self._load_balancer)
             sync_start = not self._config.async_start
@@ -494,9 +503,16 @@ def get_distributed_objects(self) -> typing.List[Proxy]:
             for dist_obj in self._proxy_manager.get_distributed_objects()
         }
 
-        response = client_get_distributed_objects_codec.decode_response(invocation.future.result())
+        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
             )
@@ -512,15 +528,19 @@ def shutdown(self) -> None:
         """Shuts down this HazelcastClient."""
         with self._shutdown_lock:
             if self._internal_lifecycle_service.running:
-                self._internal_lifecycle_service.fire_lifecycle_event(LifecycleState.SHUTTING_DOWN)
+                self._internal_lifecycle_service.fire_lifecycle_event(
+                    LifecycleState.SHUTTING_DOWN
+                )
                 self._internal_lifecycle_service.shutdown()
                 self._proxy_session_manager.shutdown().result()
                 self._near_cache_manager.destroy_near_caches()
                 self._connection_manager.shutdown()
                 self._invocation_service.shutdown()
                 self._statistics.shutdown()
                 self._reactor.shutdown()
-                self._internal_lifecycle_service.fire_lifecycle_event(LifecycleState.SHUTDOWN)
+                self._internal_lifecycle_service.fire_lifecycle_event(
+                    LifecycleState.SHUTDOWN
+                )
 
     @property
     def name(self) -> str:
@@ -573,7 +593,9 @@ def _create_address_provider(self):
 
         if cloud_enabled:
             connection_timeout = self._get_connection_timeout(config)
-            return HazelcastCloudAddressProvider(cloud_discovery_token, connection_timeout)
+            return HazelcastCloudAddressProvider(
+                cloud_discovery_token, connection_timeout
+            )
 
         return DefaultAddressProvider(cluster_members)