Update .locked() to indicate if lock has been acquired by any proceses

This make just like threading.Lock objects do.

Fixed #1007

1 files changed, 4 insertions, 2 deletions

diff --git a/redis/lock.py b/redis/lock.py
index 43c0813..c6fd01d 100644
--- a/redis/lock.py
+++ b/redis/lock.py
@@ -173,8 +173,10 @@ class Lock(object):
         return False
 
     def locked(self):
-        token = self.local.token
-        return token and self.redis.get(self.name) == token or False
+        """
+        Returns True if this key is locked by any process, otherwise False.
+        """
+        return self.redis.get(self.name) is not None
 
     def release(self):
         "Releases the already acquired lock"