diff options
| author | Mohamed Bassem <me@mbassem.com> | 2024-07-21 19:18:58 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-07-21 19:18:58 +0100 |
| commit | 9edd154440c18bcc4542560e229eb293f9e0c2d4 (patch) | |
| tree | 2423f82619d48656f8dc60870fab8b152eef4401 /packages/trpc/routers/bookmarks.ts | |
| parent | edbd98d7841388d1169a3a3b159367487bda431e (diff) | |
| download | karakeep-9edd154440c18bcc4542560e229eb293f9e0c2d4.tar.zst | |
refactor: Replace the usage of bullMQ with the hoarder sqlite-based queue (#309)
Diffstat (limited to 'packages/trpc/routers/bookmarks.ts')
| -rw-r--r-- | packages/trpc/routers/bookmarks.ts | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/packages/trpc/routers/bookmarks.ts b/packages/trpc/routers/bookmarks.ts index 1e5e7dfc..43bb4db7 100644 --- a/packages/trpc/routers/bookmarks.ts +++ b/packages/trpc/routers/bookmarks.ts @@ -310,14 +310,14 @@ export const bookmarksAppRouter = router({ switch (bookmark.content.type) { case BookmarkTypes.LINK: { // The crawling job triggers openai when it's done - await LinkCrawlerQueue.add("crawl", { + await LinkCrawlerQueue.enqueue({ bookmarkId: bookmark.id, }); break; } case BookmarkTypes.TEXT: case BookmarkTypes.ASSET: { - await OpenAIQueue.add("openai", { + await OpenAIQueue.enqueue({ bookmarkId: bookmark.id, }); break; @@ -418,7 +418,7 @@ export const bookmarksAppRouter = router({ .input(z.object({ bookmarkId: z.string() })) .use(ensureBookmarkOwnership) .mutation(async ({ input }) => { - await LinkCrawlerQueue.add("crawl", { + await LinkCrawlerQueue.enqueue({ bookmarkId: input.bookmarkId, }); }), |