Loading src/service/service/service_handlers/oc/OCServiceHandler.py +7 −3 Original line number Diff line number Diff line Loading @@ -62,16 +62,20 @@ class OCServiceHandler(_ServiceHandler): # settings = self.__settings_handler.get('/settings') #flow is the new variable that stores input-output relationship #flows = convert_endpoints_to_flows(endpoints) flows = endpoints_to_flows(endpoints, bidir, is_opticalband) flows = convert_endpoints_to_flows(endpoints) LOGGER.info(f"endpoints {endpoints} is_opticalband {is_opticalband} ") #flows = endpoints_to_flows(endpoints, bidir, is_opticalband) #handled_flows=handle_flows_names(flows=flows,task_executor=self.__task_executor) results = [] LOGGER.info(f"flows {flows} ") LOGGER.info(f"settings {settings} ") #new cycle for setting optical devices for device_uuid, dev_flows in flows.items(): try: device_obj = self.__task_executor.get_device(DeviceId(**json_device_id(device_uuid))) LOGGER.info(f"device {device_obj.name} ") if settings: self.__task_executor.configure_optical_device(device_obj, settings, dev_flows, is_opticalband) results.append(True) Loading Loading
src/service/service/service_handlers/oc/OCServiceHandler.py +7 −3 Original line number Diff line number Diff line Loading @@ -62,16 +62,20 @@ class OCServiceHandler(_ServiceHandler): # settings = self.__settings_handler.get('/settings') #flow is the new variable that stores input-output relationship #flows = convert_endpoints_to_flows(endpoints) flows = endpoints_to_flows(endpoints, bidir, is_opticalband) flows = convert_endpoints_to_flows(endpoints) LOGGER.info(f"endpoints {endpoints} is_opticalband {is_opticalband} ") #flows = endpoints_to_flows(endpoints, bidir, is_opticalband) #handled_flows=handle_flows_names(flows=flows,task_executor=self.__task_executor) results = [] LOGGER.info(f"flows {flows} ") LOGGER.info(f"settings {settings} ") #new cycle for setting optical devices for device_uuid, dev_flows in flows.items(): try: device_obj = self.__task_executor.get_device(DeviceId(**json_device_id(device_uuid))) LOGGER.info(f"device {device_obj.name} ") if settings: self.__task_executor.configure_optical_device(device_obj, settings, dev_flows, is_opticalband) results.append(True) Loading