Loading src/service/service/service_handlers/e2e_orch/E2EOrchestratorServiceHandler.py→src/service/service/service_handlers/optical_tfs/OpticalTfsServiceHandler.py +14 −14 Original line number Diff line number Diff line Loading @@ -26,9 +26,9 @@ from service.service.task_scheduler.TaskExecutor import TaskExecutor LOGGER = logging.getLogger(__name__) METRICS_POOL = MetricsPool('Service', 'Handler', labels={'handler': 'e2e_orch'}) METRICS_POOL = MetricsPool('Service', 'Handler', labels={'handler': 'optical_tfs'}) class E2EOrchestratorServiceHandler(_ServiceHandler): class OpticalTfsServiceHandler(_ServiceHandler): def __init__( # pylint: disable=super-init-not-called self, service : Service, task_executor : TaskExecutor, **settings ) -> None: Loading @@ -47,7 +47,7 @@ class E2EOrchestratorServiceHandler(_ServiceHandler): service_uuid = self.__service.service_id.service_uuid.uuid settings = self.__settings_handler.get('/settings') json_settings : Dict = {} if settings is None else settings.value bitrate = json_settings.get('bitrate', 1000) bitrate = json_settings['bitrate'] results = [] try: Loading Loading @@ -90,8 +90,8 @@ class E2EOrchestratorServiceHandler(_ServiceHandler): service_uuid = self.__service.service_id.service_uuid.uuid settings = self.__settings_handler.get('/settings') json_settings : Dict = {} if settings is None else settings.value flow_id = json_settings.get('flow_id', 100) bitrate = json_settings.get('bitrate', 1000) flow_id = json_settings['flow_id'] bitrate = json_settings['bitrate'] results = [] try: Loading src/service/service/service_handlers/e2e_orch/__init__.py→src/service/service/service_handlers/optical_tfs/__init__.py +0 −0 File moved. View file Loading
src/service/service/service_handlers/e2e_orch/E2EOrchestratorServiceHandler.py→src/service/service/service_handlers/optical_tfs/OpticalTfsServiceHandler.py +14 −14 Original line number Diff line number Diff line Loading @@ -26,9 +26,9 @@ from service.service.task_scheduler.TaskExecutor import TaskExecutor LOGGER = logging.getLogger(__name__) METRICS_POOL = MetricsPool('Service', 'Handler', labels={'handler': 'e2e_orch'}) METRICS_POOL = MetricsPool('Service', 'Handler', labels={'handler': 'optical_tfs'}) class E2EOrchestratorServiceHandler(_ServiceHandler): class OpticalTfsServiceHandler(_ServiceHandler): def __init__( # pylint: disable=super-init-not-called self, service : Service, task_executor : TaskExecutor, **settings ) -> None: Loading @@ -47,7 +47,7 @@ class E2EOrchestratorServiceHandler(_ServiceHandler): service_uuid = self.__service.service_id.service_uuid.uuid settings = self.__settings_handler.get('/settings') json_settings : Dict = {} if settings is None else settings.value bitrate = json_settings.get('bitrate', 1000) bitrate = json_settings['bitrate'] results = [] try: Loading Loading @@ -90,8 +90,8 @@ class E2EOrchestratorServiceHandler(_ServiceHandler): service_uuid = self.__service.service_id.service_uuid.uuid settings = self.__settings_handler.get('/settings') json_settings : Dict = {} if settings is None else settings.value flow_id = json_settings.get('flow_id', 100) bitrate = json_settings.get('bitrate', 1000) flow_id = json_settings['flow_id'] bitrate = json_settings['bitrate'] results = [] try: Loading
src/service/service/service_handlers/e2e_orch/__init__.py→src/service/service/service_handlers/optical_tfs/__init__.py +0 −0 File moved. View file