def acquire()

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"
            )