diff --git a/src/dlt/connector/client/DltEventsCollector.py b/src/dlt/connector/client/DltEventsCollector.py index 594d84838479e14654d5375e548994b38be4053e..e59784a4d2902459d7bc88925e5b83a698770012 100644 --- a/src/dlt/connector/client/DltEventsCollector.py +++ b/src/dlt/connector/client/DltEventsCollector.py @@ -16,7 +16,7 @@ from typing import Callable, Optional import grpc, logging, queue, threading, time from common.proto.dlt_gateway_pb2 import DltRecordEvent, DltRecordSubscription from common.tools.grpc.Tools import grpc_message_to_json_string -from src.dlt.connector.client.DltGatewayClient import DltGatewayClient +from dlt.connector.client.DltGatewayClient import DltGatewayClient LOGGER = logging.getLogger(__name__) LOGGER.setLevel(logging.DEBUG) diff --git a/src/dlt/connector/service/DltConnectorServiceServicerImpl.py b/src/dlt/connector/service/DltConnectorServiceServicerImpl.py index 17cc6fd33bbb0d87249876422bb5bab9879f0cea..1d4066fc97fb985e13002ce0424aeea853dbf96e 100644 --- a/src/dlt/connector/service/DltConnectorServiceServicerImpl.py +++ b/src/dlt/connector/service/DltConnectorServiceServicerImpl.py @@ -22,7 +22,7 @@ from common.proto.dlt_connector_pb2_grpc import DltConnectorServiceServicer from common.proto.dlt_gateway_pb2 import DltRecord, DltRecordId, DltRecordOperationEnum, DltRecordTypeEnum from common.tools.grpc.Tools import grpc_message_to_json_string from context.client.ContextClient import ContextClient -from src.dlt.connector.client.DltGatewayClientAsync import DltGatewayClientAsync +from dlt.connector.client.DltGatewayClientAsync import DltGatewayClientAsync from .tools.Checkers import record_exists LOGGER = logging.getLogger(__name__) diff --git a/src/dlt/connector/service/event_dispatcher/DltEventDispatcher.py b/src/dlt/connector/service/event_dispatcher/DltEventDispatcher.py index 4ae6fec54cb459de559e897d436f67a7b37dbe00..779bae9c19f583ec47584673da51b536cc1dc8b3 100644 --- a/src/dlt/connector/service/event_dispatcher/DltEventDispatcher.py +++ b/src/dlt/connector/service/event_dispatcher/DltEventDispatcher.py @@ -26,9 +26,9 @@ from common.tools.grpc.Tools import grpc_message_to_json_string from common.tools.object_factory.Context import json_context_id from common.tools.object_factory.Topology import json_topology_id from context.client.ContextClient import ContextClient -from src.dlt.connector.client.DltConnectorClient import DltConnectorClient +from dlt.connector.client.DltConnectorClient import DltConnectorClient from dlt.connector.client.DltEventsCollector import DltEventsCollector -from src.dlt.connector.client.DltGatewayClient import DltGatewayClient +from dlt.connector.client.DltGatewayClient import DltGatewayClient from interdomain.client.InterdomainClient import InterdomainClient LOGGER = logging.getLogger(__name__) diff --git a/src/dlt/performance/__main__.py b/src/dlt/performance/__main__.py index 09248c1b1f450b864e7117093aa310d0cfdb2bdf..1d6c419651bd561b12325dbcb0dba44461f25195 100644 --- a/src/dlt/performance/__main__.py +++ b/src/dlt/performance/__main__.py @@ -14,7 +14,7 @@ import functools, logging, pathlib, sys, time from common.proto.dlt_gateway_pb2 import DltRecordEvent -from src.dlt.connector.client.DltGatewayClient import DltGatewayClient +from dlt.connector.client.DltGatewayClient import DltGatewayClient from dlt.connector.client.DltEventsCollector import DltEventsCollector from .play_ground.Enums import CONTEXT_EVENT_TYPE_TO_ACTION, RECORD_TYPE_TO_ENUM from .play_ground import PlayGround diff --git a/src/dlt/performance/play_ground/Dlt.py b/src/dlt/performance/play_ground/Dlt.py index 5de186c8cbb0c71ee159f2890e34f479f8d41688..b2c88954581987f5bb52d2458e4d711820d0d3b6 100644 --- a/src/dlt/performance/play_ground/Dlt.py +++ b/src/dlt/performance/play_ground/Dlt.py @@ -18,7 +18,7 @@ from common.proto.context_pb2 import Device, Link, Service, Slice from common.proto.dlt_gateway_pb2 import ( DltRecord, DltRecordId, DltRecordOperationEnum, DltRecordStatus, DltRecordTypeEnum) from common.tools.grpc.Tools import grpc_message_to_json_string -from src.dlt.connector.client.DltGatewayClient import DltGatewayClient +from dlt.connector.client.DltGatewayClient import DltGatewayClient from .PerfPoint import PerfPoint DLT_OPERATION_CREATE = DltRecordOperationEnum.DLTRECORDOPERATION_ADD diff --git a/src/dlt/performance/play_ground/__init__.py b/src/dlt/performance/play_ground/__init__.py index ce34d30a4cbfab50f0b118800b00b41cac991a3d..68ad14deebd57548815db01d38cec2605e3d2a7d 100644 --- a/src/dlt/performance/play_ground/__init__.py +++ b/src/dlt/performance/play_ground/__init__.py @@ -15,7 +15,7 @@ import logging, operator, random from typing import Dict, Tuple from common.proto.context_pb2 import Device, Link, Service, Slice -from src.dlt.connector.client.DltGatewayClient import DltGatewayClient +from dlt.connector.client.DltGatewayClient import DltGatewayClient from .Enums import ActionEnum, RecordTypeEnum from .Dlt import ( DLT_OPERATION_CREATE, DLT_OPERATION_DELETE, DLT_OPERATION_UPDATE, diff --git a/src/interdomain/service/InterdomainServiceServicerImpl.py b/src/interdomain/service/InterdomainServiceServicerImpl.py index 146284aaad3b310e672df8fac46379e7cfbd8644..bce5e69203417e9026ddabc336a260216d0fd991 100644 --- a/src/interdomain/service/InterdomainServiceServicerImpl.py +++ b/src/interdomain/service/InterdomainServiceServicerImpl.py @@ -34,7 +34,7 @@ from common.tools.object_factory.Device import json_device_id from common.tools.object_factory.EndPoint import json_endpoint_id from common.tools.object_factory.Topology import json_topology_id from context.client.ContextClient import ContextClient -from src.dlt.connector.client.DltConnectorClientAsync import DltConnectorClientAsync +from dlt.connector.client.DltConnectorClientAsync import DltConnectorClientAsync from pathcomp.frontend.client.PathCompClient import PathCompClient from service.client.ServiceClient import ServiceClient from slice.client.SliceClient import SliceClient diff --git a/src/interdomain/service/topology_abstractor/DltRecordSender.py b/src/interdomain/service/topology_abstractor/DltRecordSender.py index 104f2e3784c36356e90cbf690e8285df8b4d02dd..2dd899be2b1739e0a9f04455391b552bb8ce2bde 100644 --- a/src/interdomain/service/topology_abstractor/DltRecordSender.py +++ b/src/interdomain/service/topology_abstractor/DltRecordSender.py @@ -21,7 +21,7 @@ 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 src.dlt.connector.client.DltConnectorClientAsync import DltConnectorClientAsync +from dlt.connector.client.DltConnectorClientAsync import DltConnectorClientAsync LOGGER = logging.getLogger(__name__) LOGGER.setLevel(logging.DEBUG) diff --git a/src/interdomain/service/topology_abstractor/TopologyAbstractor.py b/src/interdomain/service/topology_abstractor/TopologyAbstractor.py index 0dbb332db2a4cd00df21784fad0fde564e08d74c..2a6ef5e32ca5a973ab833e7e5d0429f65df9812b 100644 --- a/src/interdomain/service/topology_abstractor/TopologyAbstractor.py +++ b/src/interdomain/service/topology_abstractor/TopologyAbstractor.py @@ -33,7 +33,7 @@ from common.tools.object_factory.Device import json_device_id from common.tools.object_factory.Topology import json_topology_id from context.client.ContextClient import ContextClient from context.client.EventsCollector import EventsCollector -from src.dlt.connector.client.DltConnectorClient import DltConnectorClient +from dlt.connector.client.DltConnectorClient import DltConnectorClient from .AbstractDevice import AbstractDevice from .AbstractLink import AbstractLink from .DltRecordSender import DltRecordSender diff --git a/src/load_generator/load_gen/DltTools.py b/src/load_generator/load_gen/DltTools.py index 8321dffa52462675652ad5f79293208cdf6de9a0..0ac7ab3f03d29480b0e57cc9993b71c4d8324d76 100644 --- a/src/load_generator/load_gen/DltTools.py +++ b/src/load_generator/load_gen/DltTools.py @@ -19,7 +19,7 @@ from common.proto.dlt_connector_pb2 import DltDeviceId, DltLinkId, DltServiceId, from common.tools.grpc.Tools import grpc_message_to_json_string from common.tools.object_factory.Topology import json_topology_id from context.client.ContextClient import ContextClient -from src.dlt.connector.client.DltConnectorClient import DltConnectorClient +from dlt.connector.client.DltConnectorClient import DltConnectorClient def explore_entities_to_record( slice_id : Optional[SliceId] = None, service_id : Optional[ServiceId] = None diff --git a/src/load_generator/load_gen/RequestGenerator.py b/src/load_generator/load_gen/RequestGenerator.py index e6e934b684920d9fc4ea841db82d36de7c0f8733..2a3e89fe02bc2a8267d203d3134c65983cb985f2 100644 --- a/src/load_generator/load_gen/RequestGenerator.py +++ b/src/load_generator/load_gen/RequestGenerator.py @@ -27,7 +27,7 @@ from common.tools.object_factory.Service import ( from common.tools.object_factory.Slice import json_slice from common.tools.object_factory.Topology import json_topology_id from context.client.ContextClient import ContextClient -from src.dlt.connector.client.DltConnectorClient import DltConnectorClient +from dlt.connector.client.DltConnectorClient import DltConnectorClient from load_generator.tools.ListScalarRange import generate_value from .Constants import ENDPOINT_COMPATIBILITY, RequestType from .DltTools import record_device_to_dlt, record_link_to_dlt diff --git a/src/load_generator/tests/test_dlt_functional.py b/src/load_generator/tests/test_dlt_functional.py index 588200e0c26d6637786e3cfdbdab6208b1574004..f3dea3b4a83ed59cfb137eba03d312f4c87f0d45 100644 --- a/src/load_generator/tests/test_dlt_functional.py +++ b/src/load_generator/tests/test_dlt_functional.py @@ -19,7 +19,7 @@ from common.proto.dlt_connector_pb2 import DltDeviceId, DltLinkId, DltServiceId, from common.tools.object_factory.Device import json_device from common.tools.object_factory.Topology import json_topology_id from context.client.ContextClient import ContextClient -from src.dlt.connector.client.DltConnectorClient import DltConnectorClient +from dlt.connector.client.DltConnectorClient import DltConnectorClient def record_device_to_dlt( dlt_connector_client : DltConnectorClient, domain_id : TopologyId, device_id : DeviceId, delete : bool = False