Loading src/simap_connector/service/simap_updater/SimapUpdater.py +7 −7 Original line number Diff line number Diff line Loading @@ -543,13 +543,13 @@ class EventDispatcher(BaseEventDispatcher): except: # pylint: disable=bare-except pass topology_uuid, endpoint_uuids = get_service_endpoint(service) if topology_uuid is None: MSG = 'ServiceEvent({:s}) skipped, no endpoint_ids to identify topology: {:s}' str_service_event = grpc_message_to_json_string(service_event) str_service = grpc_message_to_json_string(service) LOGGER.warning(MSG.format(str_service_event, str_service)) return #topology_uuid, endpoint_uuids = get_service_endpoint(service) #if topology_uuid is None: # MSG = 'ServiceEvent({:s}) skipped, no endpoint_ids to identify topology: {:s}' # str_service_event = grpc_message_to_json_string(service_event) # str_service = grpc_message_to_json_string(service) # LOGGER.warning(MSG.format(str_service_event, str_service)) # return topologies = self._object_cache.get_all(CachedEntities.TOPOLOGY, fresh=False) topology_names = {t.name for t in topologies} Loading Loading
src/simap_connector/service/simap_updater/SimapUpdater.py +7 −7 Original line number Diff line number Diff line Loading @@ -543,13 +543,13 @@ class EventDispatcher(BaseEventDispatcher): except: # pylint: disable=bare-except pass topology_uuid, endpoint_uuids = get_service_endpoint(service) if topology_uuid is None: MSG = 'ServiceEvent({:s}) skipped, no endpoint_ids to identify topology: {:s}' str_service_event = grpc_message_to_json_string(service_event) str_service = grpc_message_to_json_string(service) LOGGER.warning(MSG.format(str_service_event, str_service)) return #topology_uuid, endpoint_uuids = get_service_endpoint(service) #if topology_uuid is None: # MSG = 'ServiceEvent({:s}) skipped, no endpoint_ids to identify topology: {:s}' # str_service_event = grpc_message_to_json_string(service_event) # str_service = grpc_message_to_json_string(service) # LOGGER.warning(MSG.format(str_service_event, str_service)) # return topologies = self._object_cache.get_all(CachedEntities.TOPOLOGY, fresh=False) topology_names = {t.name for t in topologies} Loading