Skip to content
This repository was archived by the owner on Feb 3, 2025. It is now read-only.

Commit e0a939b

Browse files
committed
fix: add jobid for bulk operations
1 parent a4d787d commit e0a939b

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/server/trpc/router/manga.ts

+6
Original file line numberDiff line numberDiff line change
@@ -411,6 +411,9 @@ export const mangaRouter = t.router({
411411
const allMangas = await ctx.prisma.manga.findMany();
412412
await checkOutOfSyncChaptersQueue.addBulk(
413413
allMangas.map((m) => ({
414+
opts: {
415+
jobId: nanoid(),
416+
},
414417
data: { mangaId: m.id },
415418
name: nanoid(),
416419
})),
@@ -445,6 +448,9 @@ export const mangaRouter = t.router({
445448
const allMangas = await ctx.prisma.manga.findMany();
446449
await fixOutOfSyncChaptersQueue.addBulk(
447450
allMangas.map((m) => ({
451+
opts: {
452+
jobId: nanoid(),
453+
},
448454
data: { mangaId: m.id },
449455
name: nanoid(),
450456
})),

0 commit comments

Comments
 (0)