aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMohamedBassem <me@mbassem.com>2026-02-04 04:06:58 -0800
committerMohamedBassem <me@mbassem.com>2026-02-04 04:14:55 -0800
commitb01be27013a11e1641448f8e38c4554be6718ba3 (patch)
tree3c87ccf7ff087343bad5765182d2dfc6e502fe0d
parente8e48a4144d2461666fa08b535c4de37d5db1b2f (diff)
downloadkarakeep-b01be27013a11e1641448f8e38c4554be6718ba3.tar.zst
fix: lower priority of mass admin actions
-rw-r--r--packages/trpc/routers/admin.ts45
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",
+ },
+ );
}),
});