fix(enqueue): only delete own queue jobs (related to #3)

mgcrea · mgcrea · commit 8bd8c21ab9ec · 2024-05-30T13:33:40.000+02:00
diff --git 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(),
