|
@@ -33,7 +33,6 @@ def acquire_lock_with_timeout(conn, lockname, acquire_timeout=5, lock_timeout=10
|
|
def release_lock(conn, lockname, identifier):
|
|
def release_lock(conn, lockname, identifier):
|
|
pipe = conn.pipeline(True)
|
|
pipe = conn.pipeline(True)
|
|
lockname = 'lock:' + lockname
|
|
lockname = 'lock:' + lockname
|
|
-
|
|
|
|
while True:
|
|
while True:
|
|
try:
|
|
try:
|
|
pipe.watch(lockname)
|
|
pipe.watch(lockname)
|
|
@@ -48,6 +47,6 @@ def release_lock(conn, lockname, identifier):
|
|
pipe.unwatch()
|
|
pipe.unwatch()
|
|
break
|
|
break
|
|
|
|
|
|
- except redis.exceptions.WatchError:
|
|
|
|
|
|
+ except (redis.exceptions.WatchError, TypeError):
|
|
pass
|
|
pass
|
|
- return False
|
|
|
|
|
|
+ return False
|