InvalidParameters as Invalid,
UndefinedAction,
)
-from .failing_connector import FailingConnector
-from .sdnconn import SdnConnectorError
-from .wimconn_fake import FakeConnector
+from osm_ro_plugin.sdn_failing import SdnFailingConnector
+from osm_ro_plugin.sdnconn import SdnConnectorError
+from osm_ro_plugin.sdn_dummy import SdnDummyConnector
ACTIONS = {
'instance_wim_nets': wan_link_actions.ACTIONS
CONNECTORS = {
# "odl": wimconn_odl.OdlConnector,
- "fake": FakeConnector,
+ "dummy": SdnDummyConnector,
# Add extra connectors here not managed via plugins
}
wim_account['name'], wim_account['uuid'])
super(WimThread, self).__init__(name=name)
self.plugins = plugins
- if "rosdn_fake" not in self.plugins:
- self.plugins["rosdn_fake"] = FakeConnector
+ if "rosdn_dummy" not in self.plugins:
+ self.plugins["rosdn_dummy"] = SdnDummyConnector
self.name = name
self.connector = None
error_msg_extra = ('Any task targeting WIM account {} ({}) will fail.'
.format(account_id, self.wim_account.get('name')))
self.logger.warning(error_msg_extra)
- return FailingConnector(error_msg + '\n' + error_msg_extra)
+ return SdnFailingConnector(error_msg + '\n' + error_msg_extra)
@contextmanager
def avoid_exceptions(self):
self.process_list('refresh')):
sleep(self.WAITING_TIME)
- if isinstance(self.connector, FailingConnector):
+ if isinstance(self.connector, SdnFailingConnector):
# Wait sometime to try instantiating the connector
# again and restart
# Increase the recovery time if restarting is not