Show More
@@ -306,6 +306,9 b' def get_mutex_lock(client, lock_key, loc' | |||||
306 | return self.lock.acquire(wait) |
|
306 | return self.lock.acquire(wait) | |
307 | except redis_lock.AlreadyAcquired: |
|
307 | except redis_lock.AlreadyAcquired: | |
308 | return False |
|
308 | return False | |
|
309 | except redis_lock.AlreadyStarted: | |||
|
310 | # refresh thread exists, but it also means we acquired the lock | |||
|
311 | return True | |||
309 |
|
312 | |||
310 | def release(self): |
|
313 | def release(self): | |
311 | try: |
|
314 | try: |
General Comments 0
You need to be logged in to leave comments.
Login now