diff options
| author | MohamedBassem <me@mbassem.com> | 2024-04-02 12:58:33 +0100 |
|---|---|---|
| committer | MohamedBassem <me@mbassem.com> | 2024-04-02 12:59:31 +0100 |
| commit | 79321f83293bc37d37af4b0a0b2bd324f5bafe1a (patch) | |
| tree | e56e819240eebc0d65e5a85a996d4751e458c4b1 /apps/workers/crawlerWorker.ts | |
| parent | c73dde43cc816b8bf8eee74051d4fdac402cc710 (diff) | |
| download | karakeep-79321f83293bc37d37af4b0a0b2bd324f5bafe1a.tar.zst | |
fix(workers): Add a timeout to the crawling job to prevent it from getting stuck. Fixes #63
Diffstat (limited to 'apps/workers/crawlerWorker.ts')
| -rw-r--r-- | apps/workers/crawlerWorker.ts | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/apps/workers/crawlerWorker.ts b/apps/workers/crawlerWorker.ts index 87b785ad..a969ab86 100644 --- a/apps/workers/crawlerWorker.ts +++ b/apps/workers/crawlerWorker.ts @@ -20,6 +20,7 @@ import metascraperUrl from "metascraper-url"; import puppeteer from "puppeteer-extra"; import AdblockerPlugin from "puppeteer-extra-plugin-adblocker"; import StealthPlugin from "puppeteer-extra-plugin-stealth"; +import { withTimeout } from "utils"; import type { ZCrawlLinkRequest } from "@hoarder/shared/queues"; import { db } from "@hoarder/db"; @@ -110,7 +111,7 @@ export class CrawlerWorker { logger.info("Starting crawler worker ..."); const worker = new Worker<ZCrawlLinkRequest, void>( LinkCrawlerQueue.name, - runCrawler, + withTimeout(runCrawler, /* timeoutSec */ 30), { connection: queueConnectionDetails, autorun: false, |
