diff --git a/ovn_octavia_provider/helper.py b/ovn_octavia_provider/helper.py index c1edf907..1f7fa6fb 100644 --- a/ovn_octavia_provider/helper.py +++ b/ovn_octavia_provider/helper.py @@ -116,6 +116,7 @@ class OvnProviderHelper(object): self.requests.put({'type': ovn_const.REQ_TYPE_EXIT}) self.helper_thread.join() self.ovn_nbdb.stop() + del self.ovn_nbdb_api @staticmethod def _map_val(row, col, key): diff --git a/ovn_octavia_provider/ovsdb/impl_idl_ovn.py b/ovn_octavia_provider/ovsdb/impl_idl_ovn.py index e8731d81..124f620f 100644 --- a/ovn_octavia_provider/ovsdb/impl_idl_ovn.py +++ b/ovn_octavia_provider/ovsdb/impl_idl_ovn.py @@ -175,10 +175,11 @@ class OvnNbIdlForLb(ovsdb_monitor.OvnIdl): def stop(self): # Close the running connection if it has been initalized - if ((hasattr(self, 'conn') and not - self.conn.stop(timeout=config.get_ovn_ovsdb_timeout()))): - LOG.debug("Connection terminated to OvnNb " - "but a thread is still alive") + if hasattr(self, 'conn'): + if not self.conn.stop(timeout=config.get_ovn_ovsdb_timeout()): + LOG.debug("Connection terminated to OvnNb " + "but a thread is still alive") + del self.conn # complete the shutdown for the event handler self.notify_handler.shutdown() # Close the idl session