delete needs to account for namespace

2026-01-23 05:47:59 -05:00 · 2026-01-22 18:08:55 -08:00
parent e0d301aca7
commit 03bb2d2763
1 changed files with 6 additions and 1 deletions
--- a/apps/sim/lib/core/idempotency/service.ts
+++ b/apps/sim/lib/core/idempotency/service.ts
@@ -148,7 +148,12 @@ export class IdempotencyService {

      await db
        .delete(idempotencyKey)
-        .where(eq(idempotencyKey.key, normalizedKey))
+        .where(
+          and(
+            eq(idempotencyKey.key, normalizedKey),
+            eq(idempotencyKey.namespace, this.config.namespace)
+          )
+        )
        .catch((err) => logger.warn(`Failed to clean up expired key ${normalizedKey}:`, err))
    }