From 8bd8c21ab9ec34dccd4eac9fb59e7f08ccd7c1ee Mon Sep 17 00:00:00 2001
From: Olivier Louvignes <olivier@mgcrea.io>
Date: Thu, 30 May 2024 13:33:40 +0200
Subject: [PATCH] fix(enqueue): only delete own queue jobs (related to #3)

---
 src/PrismaQueue.ts | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/PrismaQueue.ts b/src/PrismaQueue.ts
index 7b370de..47602b2 100644
--- a/src/PrismaQueue.ts
+++ b/src/PrismaQueue.ts
@@ -148,6 +148,7 @@ export class PrismaQueue<
       if (key && runAt) {
         const { count } = await this.model.deleteMany({
           where: {
+            queue: queueName,
             key,
             runAt: {
               gte: new Date(),