diff options
| author | Mohamed Bassem <me@mbassem.com> | 2024-10-27 23:37:54 +0000 |
|---|---|---|
| committer | Mohamed Bassem <me@mbassem.com> | 2024-10-27 23:40:10 +0000 |
| commit | a746e9a38e53e4a9114d786c7fb1b3ef4ca67870 (patch) | |
| tree | bf1d819f6faca01bc7c3db1efe91c0879caaf4a8 /apps/workers | |
| parent | eb7da996a7c2d617d276f296cac07a6fd5648664 (diff) | |
| download | karakeep-a746e9a38e53e4a9114d786c7fb1b3ef4ca67870.tar.zst | |
deps: Extract the queue implementation into its own repos
Diffstat (limited to 'apps/workers')
| -rw-r--r-- | apps/workers/crawlerWorker.ts | 2 | ||||
| -rw-r--r-- | apps/workers/openaiWorker.ts | 2 | ||||
| -rw-r--r-- | apps/workers/package.json | 2 | ||||
| -rw-r--r-- | apps/workers/searchWorker.ts | 2 | ||||
| -rw-r--r-- | apps/workers/tidyAssetsWorker.ts | 2 |
5 files changed, 5 insertions, 5 deletions
diff --git a/apps/workers/crawlerWorker.ts b/apps/workers/crawlerWorker.ts index 74413c63..ca0f6608 100644 --- a/apps/workers/crawlerWorker.ts +++ b/apps/workers/crawlerWorker.ts @@ -9,6 +9,7 @@ import { eq } from "drizzle-orm"; import { execa } from "execa"; import { isShuttingDown } from "exit"; import { JSDOM } from "jsdom"; +import { DequeuedJob, Runner } from "liteque"; import metascraper from "metascraper"; import metascraperAmazon from "metascraper-amazon"; import metascraperDescription from "metascraper-description"; @@ -32,7 +33,6 @@ import { bookmarkLinks, bookmarks, } from "@hoarder/db/schema"; -import { DequeuedJob, Runner } from "@hoarder/queue"; import { ASSET_TYPES, deleteAsset, diff --git a/apps/workers/openaiWorker.ts b/apps/workers/openaiWorker.ts index 4fe74f44..5a4fd69d 100644 --- a/apps/workers/openaiWorker.ts +++ b/apps/workers/openaiWorker.ts @@ -1,4 +1,5 @@ import { and, Column, eq, inArray, sql } from "drizzle-orm"; +import { DequeuedJob, Runner } from "liteque"; import { z } from "zod"; import type { InferenceClient } from "@hoarder/shared/inference"; @@ -11,7 +12,6 @@ import { customPrompts, tagsOnBookmarks, } from "@hoarder/db/schema"; -import { DequeuedJob, Runner } from "@hoarder/queue"; import { readAsset } from "@hoarder/shared/assetdb"; import serverConfig from "@hoarder/shared/config"; import { InferenceClientFactory } from "@hoarder/shared/inference"; diff --git a/apps/workers/package.json b/apps/workers/package.json index 289f7315..7f64e715 100644 --- a/apps/workers/package.json +++ b/apps/workers/package.json @@ -5,7 +5,6 @@ "private": true, "dependencies": { "@hoarder/db": "workspace:^0.1.0", - "@hoarder/queue": "workspace:^0.1.0", "@hoarder/shared": "workspace:^0.1.0", "@hoarder/tsconfig": "workspace:^0.1.0", "@mozilla/readability": "^0.5.0", @@ -16,6 +15,7 @@ "drizzle-orm": "^0.33.0", "execa": "9.3.1", "jsdom": "^24.0.0", + "liteque": "^0.1.3", "metascraper": "^5.45.24", "metascraper-amazon": "^5.45.22", "metascraper-description": "^5.45.22", diff --git a/apps/workers/searchWorker.ts b/apps/workers/searchWorker.ts index f793f3f6..d2f1dffc 100644 --- a/apps/workers/searchWorker.ts +++ b/apps/workers/searchWorker.ts @@ -1,9 +1,9 @@ import { eq } from "drizzle-orm"; +import { DequeuedJob, Runner } from "liteque"; import type { ZSearchIndexingRequest } from "@hoarder/shared/queues"; import { db } from "@hoarder/db"; import { bookmarks } from "@hoarder/db/schema"; -import { DequeuedJob, Runner } from "@hoarder/queue"; import logger from "@hoarder/shared/logger"; import { SearchIndexingQueue, diff --git a/apps/workers/tidyAssetsWorker.ts b/apps/workers/tidyAssetsWorker.ts index bc14aab9..c70736f2 100644 --- a/apps/workers/tidyAssetsWorker.ts +++ b/apps/workers/tidyAssetsWorker.ts @@ -1,8 +1,8 @@ import { eq } from "drizzle-orm"; +import { DequeuedJob, Runner } from "liteque"; import { db } from "@hoarder/db"; import { assets } from "@hoarder/db/schema"; -import { DequeuedJob, Runner } from "@hoarder/queue"; import { deleteAsset, getAllAssets } from "@hoarder/shared/assetdb"; import logger from "@hoarder/shared/logger"; import { |
