Log exceptions deleting ZK nodes
Change-Id: I58836dafbf0846a4d6beb4a2ae5b8dfde3d5aec8
This commit is contained in:
parent
a0e4ff87f7
commit
bd10ff9540
|
@ -106,7 +106,11 @@ class NodeDeleter(threading.Thread):
|
||||||
else:
|
else:
|
||||||
node_exists = True
|
node_exists = True
|
||||||
|
|
||||||
self.delete(self._zk, self._provider_manager, self._node, node_exists)
|
try:
|
||||||
|
self.delete(self._zk, self._provider_manager,
|
||||||
|
self._node, node_exists)
|
||||||
|
except Exception:
|
||||||
|
self.log.exception("Error deleting node %s:", self._node)
|
||||||
|
|
||||||
|
|
||||||
class PoolWorker(threading.Thread, stats.StatsReporter):
|
class PoolWorker(threading.Thread, stats.StatsReporter):
|
||||||
|
|
Loading…
Reference in New Issue