Log exceptions deleting ZK nodes

Change-Id: I58836dafbf0846a4d6beb4a2ae5b8dfde3d5aec8
This commit is contained in:
James E. Blair 2018-11-30 14:20:34 -08:00
parent a0e4ff87f7
commit bd10ff9540
1 changed files with 5 additions and 1 deletions

View File

@ -106,7 +106,11 @@ class NodeDeleter(threading.Thread):
else:
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):