Commit c33f9ae6 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Service component: 

- Updated (De)Configure Task to report nodes also for NCE controller
parent 01774cd7

src/service/service/task_scheduler/tasks/Task_ConnectionConfigure.py

+6 −1
Original line number Diff line number Diff line
@@ -28,6 +28,11 @@ if TYPE_CHECKING: 


KEY_TEMPLATE = 'connection({connection_id:s}):configure'



CONTROLLER_DEVICE_TYPES = {

    DeviceTypeEnum.TERAFLOWSDN_CONTROLLER,

    DeviceTypeEnum.NCE,

}



class Task_ConnectionConfigure(_Task):

    def __init__(self, task_executor : TaskExecutor, connection_id : ConnectionId) -> None:

        super().__init__(task_executor)
@@ -57,7 +62,7 @@ class Task_ConnectionConfigure(_Task): 


        errors = list()

        for device_type, (service_handler, connection_devices) in service_handlers.items():

            if device_type == DeviceTypeEnum.TERAFLOWSDN_CONTROLLER:

            if device_type in CONTROLLER_DEVICE_TYPES:

                _endpointids_to_set = endpointids_to_set

            else:

                _endpointids_to_set = [

src/service/service/task_scheduler/tasks/Task_ConnectionDeconfigure.py

+6 −1
Original line number Diff line number Diff line
@@ -28,6 +28,11 @@ if TYPE_CHECKING: 


KEY_TEMPLATE = 'connection({connection_id:s}):deconfigure'



CONTROLLER_DEVICE_TYPES = {

    DeviceTypeEnum.TERAFLOWSDN_CONTROLLER,

    DeviceTypeEnum.NCE,

}



class Task_ConnectionDeconfigure(_Task):

    def __init__(self, task_executor : TaskExecutor, connection_id : ConnectionId) -> None:

        super().__init__(task_executor)
@@ -57,7 +62,7 @@ class Task_ConnectionDeconfigure(_Task): 


        errors = list()

        for device_type, (service_handler, connection_devices) in service_handlers.items():

            if device_type == DeviceTypeEnum.TERAFLOWSDN_CONTROLLER:

            if device_type in CONTROLLER_DEVICE_TYPES:

                _endpointids_to_delete = endpointids_to_delete

            else:

                _endpointids_to_delete = [