diff --git a/apps/sim/lib/core/idempotency/service.ts b/apps/sim/lib/core/idempotency/service.ts
index aa2bcbe96..e0c84002b 100644
--- 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))
     }