From 47ba0a8a32d6a91e520bfe5b5279690537a928df Mon Sep 17 00:00:00 2001 From: darkskygit Date: Mon, 30 Dec 2024 09:25:31 +0000 Subject: [PATCH] fix(server): same identify across pods (#9428) --- packages/backend/server/src/base/mutex/mutex.ts | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/packages/backend/server/src/base/mutex/mutex.ts b/packages/backend/server/src/base/mutex/mutex.ts index fc1e640308..d78f606317 100644 --- a/packages/backend/server/src/base/mutex/mutex.ts +++ b/packages/backend/server/src/base/mutex/mutex.ts @@ -14,6 +14,7 @@ export const MUTEX_WAIT = 100; @Injectable() export class Mutex { protected logger = new Logger(Mutex.name); + private readonly clusterIdentifier = `cluster:${randomUUID()}`; constructor(protected readonly locker: Locker) {} @@ -38,7 +39,7 @@ export class Mutex { * @param key resource key * @returns LockGuard */ - async acquire(key: string, owner: string = 'global') { + async acquire(key: string, owner: string = this.clusterIdentifier) { try { return await retryable( () => this.locker.lock(owner, key),