Show More
@@ -306,6 +306,9 b' def get_mutex_lock(client, lock_key, loc' | |||
|
306 | 306 | return self.lock.acquire(wait) |
|
307 | 307 | except redis_lock.AlreadyAcquired: |
|
308 | 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 | 313 | def release(self): |
|
311 | 314 | try: |
General Comments 0
You need to be logged in to leave comments.
Login now