Merge pull request #657 from syseleven/sneubauer/fix-deprecation-warning

fix(recipe): fix deprecation warning from threading.Event

Author: ceache

kazoo/recipe/lock.py

@@ -276,7 +276,7 @@ def _inner_acquire(self, blocking, timeout, ephemeral=True):
                 pass  # predecessor has already been deleted
             else:
                 self.wake_event.wait(timeout)
-                if not self.wake_event.isSet():
+                if not self.wake_event.is_set():
                     raise LockTimeout(
                         "Failed to acquire lock on %s after %s seconds"
                         % (self.path, timeout)
@@ -638,7 +638,7 @@ def _inner_acquire(self, blocking, timeout=None):
                     # If blocking, wait until self._watch_lease_change() is
                     # called before returning
                     self.wake_event.wait(w.leftover())
-                    if not self.wake_event.isSet():
+                    if not self.wake_event.is_set():
                         raise LockTimeout(
                             "Failed to acquire semaphore on %s"
                             " after %s seconds" % (self.path, timeout)

kazoo/recipe/queue.py

@@ -292,7 +292,7 @@ def check_for_updates(event):
             if event is not None and event.type != EventType.CHILD:
                 return
             with lock:
-                if canceled or flag.isSet():
+                if canceled or flag.is_set():
                     return
                 values = self.client.retry(
                     self.client.get_children,

kazoo/testing/harness.py

@@ -229,11 +229,11 @@ def watch_loss(state):
         self.client._call(break_event, None)
 
         lost.wait(5)
-        if not lost.isSet():
+        if not lost.is_set():
             raise Exception("Failed to get notified of broken connection.")
 
         safe.wait(15)
-        if not safe.isSet():
+        if not safe.is_set():
             raise Exception("Failed to see client reconnect.")
 
         self.client.retry(self.client.get_async, '/')

kazoo/tests/test_lock.py

@@ -397,7 +397,7 @@ def _thread(lock, event, timeout):
             with lock:
                 started.set()
                 event.wait(timeout)
-                if not event.isSet():
+                if not event.is_set():
                     # Eventually fail to avoid hanging the tests
                     self.fail("lock2 never timed out")
 
@@ -409,7 +409,7 @@ def _thread(lock, event, timeout):
         client2 = self._get_client()
         client2.start()
         started.wait(5)
-        assert started.isSet() is True
+        assert started.is_set() is True
         lock2 = client2.Lock(self.lockpath, "two")
         try:
             lock2.acquire(timeout=timeout)
@@ -712,7 +712,7 @@ def _thread(sem, event, timeout):
             with sem:
                 started.set()
                 event.wait(timeout)
-                if not event.isSet():
+                if not event.is_set():
                     # Eventually fail to avoid hanging the tests
                     self.fail("sem2 never timed out")
 
@@ -724,7 +724,7 @@ def _thread(sem, event, timeout):
         client2 = self._get_client()
         client2.start()
         started.wait(5)
-        assert started.isSet() is True
+        assert started.is_set() is True
         sem2 = client2.Semaphore(self.lockpath, "two")
         try:
             sem2.acquire(timeout=timeout)