diff options
| author | MohamedBassem <me@mbassem.com> | 2026-02-04 04:06:58 -0800 |
|---|---|---|
| committer | MohamedBassem <me@mbassem.com> | 2026-02-04 04:14:55 -0800 |
| commit | b01be27013a11e1641448f8e38c4554be6718ba3 (patch) | |
| tree | 3c87ccf7ff087343bad5765182d2dfc6e502fe0d | |
| parent | e8e48a4144d2461666fa08b535c4de37d5db1b2f (diff) | |
| download | karakeep-b01be27013a11e1641448f8e38c4554be6718ba3.tar.zst | |
fix: lower priority of mass admin actions
| -rw-r--r-- | packages/trpc/routers/admin.ts | 45 |
1 files 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", + }, + ); }), }); |
