Merge pull request #418 from josephaltmaier/master

Always call _safe_close() on KazooClient.stop() so we don't leak work…
python-zk · May 31, 2017 · c82a98b · c82a98b
2 parents c85969a + fa47be4
commit c82a98b
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/kazoo/client.py b/kazoo/client.py
@@ -615,8 +615,10 @@ def stop(self):
 
         self._stopped.set()
         self._queue.append((CloseInstance, None))
-        self._connection._write_sock.send(b'\0')
-        self._safe_close()
+        try:
+            self._connection._write_sock.send(b'\0')
+        finally:
+            self._safe_close()
 
     def restart(self):
         """Stop and restart the Zookeeper session."""