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

mgcrea · May 30, 2024 · 8bd8c21 · 8bd8c21
1 parent 07de9bd
commit 8bd8c21
Showing 1 changed file with 1 addition and 0 deletions.
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(),