Loading src/interdomain/service/topology_abstractor/DltRecordSender.py +2 −1 Original line number Diff line number Diff line Loading @@ -16,6 +16,7 @@ import logging from typing import Dict, List, Optional, Tuple from common.proto.context_pb2 import Device, Link, Service, Slice, TopologyId from common.proto.dlt_connector_pb2 import DltDeviceId, DltLinkId, DltServiceId, DltSliceId from common.tools.grpc.Tools import grpc_message_to_json_string from context.client.ContextClient import ContextClient from dlt.connector.client.DltConnectorClient import DltConnectorClient from .Types import DltRecordTypes Loading Loading @@ -66,7 +67,7 @@ class DltRecordSender: topology_id,dlt_record = self.dlt_record_uuid_to_data[dlt_record_uuid] if isinstance(dlt_record, Device): device_id = self.context_client.SetDevice(dlt_record) # Se retriggerea el Evento. LOGGER.debug('DEVICE_ID: ({:s})'.format(str(device_id))) LOGGER.debug('DEVICE_ID: ({:s})'.format(grpc_message_to_json_string(device_id))) if self.dlt_connector_client is None: continue dlt_device_id = DltDeviceId() dlt_device_id.topology_id.CopyFrom(topology_id) # pylint: disable=no-member Loading Loading
src/interdomain/service/topology_abstractor/DltRecordSender.py +2 −1 Original line number Diff line number Diff line Loading @@ -16,6 +16,7 @@ import logging from typing import Dict, List, Optional, Tuple from common.proto.context_pb2 import Device, Link, Service, Slice, TopologyId from common.proto.dlt_connector_pb2 import DltDeviceId, DltLinkId, DltServiceId, DltSliceId from common.tools.grpc.Tools import grpc_message_to_json_string from context.client.ContextClient import ContextClient from dlt.connector.client.DltConnectorClient import DltConnectorClient from .Types import DltRecordTypes Loading Loading @@ -66,7 +67,7 @@ class DltRecordSender: topology_id,dlt_record = self.dlt_record_uuid_to_data[dlt_record_uuid] if isinstance(dlt_record, Device): device_id = self.context_client.SetDevice(dlt_record) # Se retriggerea el Evento. LOGGER.debug('DEVICE_ID: ({:s})'.format(str(device_id))) LOGGER.debug('DEVICE_ID: ({:s})'.format(grpc_message_to_json_string(device_id))) if self.dlt_connector_client is None: continue dlt_device_id = DltDeviceId() dlt_device_id.topology_id.CopyFrom(topology_id) # pylint: disable=no-member Loading