From 6e51637cdfbdd4f0a0e155530c46383632293afc Mon Sep 17 00:00:00 2001
From: michaelmass <10071388+michaelmass@users.noreply.github.com>
Date: Fri, 25 Aug 2023 13:42:12 -0400
Subject: [PATCH] update

---
 packages/engine/src/distributed/redis/subservice.ts | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/packages/engine/src/distributed/redis/subservice.ts b/packages/engine/src/distributed/redis/subservice.ts
index 2521ccba6..ad8ca709f 100644
--- a/packages/engine/src/distributed/redis/subservice.ts
+++ b/packages/engine/src/distributed/redis/subservice.ts
@@ -167,6 +167,7 @@ export class RedisSubservice implements DistributedSubservice {
         void this.refresh(ressource)
       }, DEFAULT_LOCK_TTL / 6)
     } catch (e) {
+      delete this.locks[ressource]
       this.logger.error(e, `Failed to extend lock ${ressource}`)
     }
   }
@@ -176,7 +177,10 @@ export class RedisSubservice implements DistributedSubservice {
       clearTimeout(lock.timeout)
     }
 
-    await this.redlock.release(lock.lock)
+    await this.redlock.release(lock.lock).catch((e: Error) => {
+      this.logger.error(e, `Failed to release lock ${lock.ressource}`)
+    })
+
     delete this.locks[lock.ressource]
   }