From b01be27013a11e1641448f8e38c4554be6718ba3 Mon Sep 17 00:00:00 2001 From: MohamedBassem Date: Wed, 4 Feb 2026 04:06:58 -0800 Subject: fix: lower priority of mass admin actions --- packages/trpc/routers/admin.ts | 45 +++++++++++++++++++++++++++++++----------- 1 file changed, 33 insertions(+), 12 deletions(-) diff --git a/packages/trpc/routers/admin.ts b/packages/trpc/routers/admin.ts index 3236529d..48d09ad2 100644 --- a/packages/trpc/routers/admin.ts +++ b/packages/trpc/routers/admin.ts @@ -662,9 +662,15 @@ export const adminAppRouter = router({ }); } - await LinkCrawlerQueue.enqueue({ - bookmarkId: input.bookmarkId, - }); + await LinkCrawlerQueue.enqueue( + { + bookmarkId: input.bookmarkId, + }, + { + priority: 50, + groupId: "admin", + }, + ); }), adminReindexBookmark: adminProcedure .input(z.object({ bookmarkId: z.string() })) @@ -681,7 +687,10 @@ export const adminAppRouter = router({ }); } - await triggerSearchReindex(input.bookmarkId); + await triggerSearchReindex(input.bookmarkId, { + priority: 50, + groupId: "admin", + }); }), adminRetagBookmark: adminProcedure .input(z.object({ bookmarkId: z.string() })) @@ -698,10 +707,16 @@ export const adminAppRouter = router({ }); } - await OpenAIQueue.enqueue({ - bookmarkId: input.bookmarkId, - type: "tag", - }); + await OpenAIQueue.enqueue( + { + bookmarkId: input.bookmarkId, + type: "tag", + }, + { + priority: 50, + groupId: "admin", + }, + ); }), adminResummarizeBookmark: adminProcedure .input(z.object({ bookmarkId: z.string() })) @@ -725,9 +740,15 @@ export const adminAppRouter = router({ }); } - await OpenAIQueue.enqueue({ - bookmarkId: input.bookmarkId, - type: "summarize", - }); + await OpenAIQueue.enqueue( + { + bookmarkId: input.bookmarkId, + type: "summarize", + }, + { + priority: 50, + groupId: "admin", + }, + ); }), }); -- cgit v1.2.3-70-g09d2