Merge pull request #430 from anskornyakov/hotfix/semaphore-deadlock

fix deadlock in nonblocking semaphore acquiring

1 files changed, 3 insertions, 3 deletions

diff --git a/kazoo/recipe/lock.py b/kazoo/recipe/lock.py
index 85af430..72d1da9 100644
--- a/kazoo/recipe/lock.py
+++ b/kazoo/recipe/lock.py
@@ -557,10 +557,10 @@ class Semaphore(object):
         w = _Watch(duration=timeout)
         w.start()
         lock = self.client.Lock(self.lock_path, self.data)
-        gotten = lock.acquire(blocking=blocking, timeout=w.leftover())
-        if not gotten:
-            return False
         try:
+            gotten = lock.acquire(blocking=blocking, timeout=w.leftover())
+            if not gotten:
+                return False
             while True:
                 self.wake_event.clear()