From bbd65fd6123f7d1a93d1f6a68f2b933d53ec3c23 Mon Sep 17 00:00:00 2001 From: Mohamed Bassem Date: Sun, 8 Feb 2026 02:11:51 +0000 Subject: feat: Add separate queue for import link crawling (#2452) * feat: add separate queue for import link crawling --------- Co-authored-by: Claude --- apps/workers/index.ts | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) (limited to 'apps/workers/index.ts') diff --git a/apps/workers/index.ts b/apps/workers/index.ts index 931a505f..c7b9533d 100644 --- a/apps/workers/index.ts +++ b/apps/workers/index.ts @@ -10,6 +10,7 @@ import { initTracing, LinkCrawlerQueue, loadAllPlugins, + LowPriorityCrawlerQueue, OpenAIQueue, prepareQueue, RuleEngineQueue, @@ -38,7 +39,11 @@ import { WebhookWorker } from "./workers/webhookWorker"; const workerBuilders = { crawler: async () => { await LinkCrawlerQueue.ensureInit(); - return CrawlerWorker.build(); + return CrawlerWorker.build(LinkCrawlerQueue); + }, + lowPriorityCrawler: async () => { + await LowPriorityCrawlerQueue.ensureInit(); + return CrawlerWorker.build(LowPriorityCrawlerQueue); }, inference: async () => { await OpenAIQueue.ensureInit(); -- cgit v1.2.3-70-g09d2