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
hoarder-app · Sep 26, 2024 · 7cc2f8b · 7cc2f8b
1 parent 4db50c2
commit 7cc2f8b
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git 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
@@ -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
@@ -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();
         },
       },