fix: add jobid for bulk operations

oae · Jan 28, 2023 · e0a939b · e0a939b
1 parent a4d787d
commit e0a939b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/server/trpc/router/manga.ts b/src/server/trpc/router/manga.ts
@@ -411,6 +411,9 @@ export const mangaRouter = t.router({
         const allMangas = await ctx.prisma.manga.findMany();
         await checkOutOfSyncChaptersQueue.addBulk(
           allMangas.map((m) => ({
+            opts: {
+              jobId: nanoid(),
+            },
             data: { mangaId: m.id },
             name: nanoid(),
           })),
@@ -445,6 +448,9 @@ export const mangaRouter = t.router({
         const allMangas = await ctx.prisma.manga.findMany();
         await fixOutOfSyncChaptersQueue.addBulk(
           allMangas.map((m) => ({
+            opts: {
+              jobId: nanoid(),
+            },
             data: { mangaId: m.id },
             name: nanoid(),
           })),