fix(recipe): Delete lock node in queue recipe if entry already consumed

Delete lock node if already entry already consumed

Fix #366 

Related: #347 / #373

Author: Khaled Basbous

kazoo/recipe/queue.py

@@ -335,10 +335,19 @@ def _take(self, id_):
                     id=id_),
                 self.id,
                 ephemeral=True)
+        except NodeExistsError:
+            # Item is already locked
+            return None
+
+        try:
             value, stat = self.client.retry(
                 self.client.get,
                 "{path}/{id}".format(path=self._entries_path, id=id_))
-        except (NoNodeError, NodeExistsError):
-            # Item is already consumed or locked
+        except NoNodeError:
+            # Item is already consumed
+            self.client.delete(
+                "{path}/{id}".format(
+                    path=self._lock_path,
+                    id=id_))
             return None
         return (id_, value)