in src/worker/helpers/lock_helper.py [0:0]
def acquire(self):
retry = 0
while retry < 3:
try:
self.lock.acquire()
break
except BaseException: # try 3 times
retry = retry + 1
if retry >= 3:
raise Exception(
"Failed to update job. Could not aquire lock for shared memory"
)