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(),