perf: add processedAt to dequeue index

mgcrea · mgcrea · commit ecf0fc37fb7f · 2026-02-13T22:31:33.000+01:00
diff --git a/prisma/schema.prisma b/prisma/schema.prisma
@@ -32,6 +32,6 @@ model QueueJob {
   updatedAt   DateTime  @updatedAt
 
   @@unique([key, runAt])
-  @@index([queue, finishedAt, priority, runAt])
+  @@index([queue, finishedAt, processedAt, priority, runAt])
   @@map("queue_jobs")
 }

Original file line number	Diff line number	Diff line change
`@@ -32,6 +32,6 @@ model QueueJob {`
`32`	`32`	`updatedAt DateTime @updatedAt`
`33`	`33`
`34`	`34`	`@@unique([key, runAt])`
`35`		`- @@index([queue, finishedAt, priority, runAt])`
	`35`	`+ @@index([queue, finishedAt, processedAt, priority, runAt])`
`36`	`36`	`@@map("queue_jobs")`
`37`	`37`	`}`