diff options
| author | kamtschatka <simon.schatka@gmx.at> | 2024-09-26 23:39:21 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-09-26 22:39:21 +0100 |
| commit | 7cc2f8b3d4afbee28e6f7e19c086077873bc7a2f (patch) | |
| tree | 3067c31793ce5d20716a6f4e07018566fdeb8f88 /apps/workers | |
| parent | 4db50c234fb0da8747b902a7c1e551cc54451f4c (diff) | |
| download | karakeep-7cc2f8b3d4afbee28e6f7e19c086077873bc7a2f.tar.zst | |
fix(workers): Log stacktrace on worker error. #424 (#429)
extended logging when an exception occurrs, so it is possible to see the stacktrace of a failed execution
Diffstat (limited to 'apps/workers')
| -rw-r--r-- | apps/workers/crawlerWorker.ts | 4 | ||||
| -rw-r--r-- | apps/workers/openaiWorker.ts | 2 | ||||
| -rw-r--r-- | apps/workers/searchWorker.ts | 4 |
3 files changed, 7 insertions, 3 deletions
diff --git a/apps/workers/crawlerWorker.ts b/apps/workers/crawlerWorker.ts index 76348821..49e9495d 100644 --- a/apps/workers/crawlerWorker.ts +++ b/apps/workers/crawlerWorker.ts @@ -172,7 +172,9 @@ export class CrawlerWorker { }, onError: async (job) => { const jobId = job?.id ?? "unknown"; - logger.error(`[Crawler][${jobId}] Crawling job failed: ${job.error}`); + logger.error( + `[Crawler][${jobId}] Crawling job failed: ${job.error}\n${job.error.stack}`, + ); const bookmarkId = job.data?.bookmarkId; if (bookmarkId) { await changeBookmarkStatus(bookmarkId, "failure"); diff --git a/apps/workers/openaiWorker.ts b/apps/workers/openaiWorker.ts index 8bd2cf4a..9b352811 100644 --- a/apps/workers/openaiWorker.ts +++ b/apps/workers/openaiWorker.ts @@ -73,7 +73,7 @@ export class OpenAiWorker { onError: async (job) => { const jobId = job?.id ?? "unknown"; logger.error( - `[inference][${jobId}] inference job failed: ${job.error}`, + `[inference][${jobId}] inference job failed: ${job.error}\n${job.error.stack}`, ); await attemptMarkTaggingStatus(job?.data, "failure"); }, diff --git a/apps/workers/searchWorker.ts b/apps/workers/searchWorker.ts index 56c2aac4..fd0514d6 100644 --- a/apps/workers/searchWorker.ts +++ b/apps/workers/searchWorker.ts @@ -25,7 +25,9 @@ export class SearchIndexingWorker { }, onError: (job) => { const jobId = job?.id ?? "unknown"; - logger.error(`[search][${jobId}] search job failed: ${job.error}`); + logger.error( + `[search][${jobId}] search job failed: ${job.error}\n${job.error.stack}`, + ); return Promise.resolve(); }, }, |