Commit ea441106 authored by Daniel Scheffler's avatar Daniel Scheffler
Browse files

Added stale_client_timeout to MemoryReserverAcquisitionLock.

parent 6d7433a9
......@@ -203,7 +203,8 @@ class MemoryReserverAcquisitionLock(Semaphore):
if not self.disabled:
super(MemoryReserverAcquisitionLock, self).__init__(client=redis_conn, count=1,
namespace='MemoryReserverAcquisitionLock', **kwargs)
namespace='MemoryReserverAcquisitionLock',
stale_client_timeout=10, **kwargs)
@property
def grabbed_key_jobID(self):
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment