aboutsummaryrefslogtreecommitdiffstats
path: root/apps/workers/tidyAssetsWorker.ts
diff options
context:
space:
mode:
authorMohamed Bassem <me@mbassem.com>2024-11-09 14:00:27 +0000
committerMohamed Bassem <me@mbassem.com>2024-11-09 14:00:27 +0000
commitf8bed574ae11a29c9c59f7d96721805188a507db (patch)
tree1f897f80976c1264eb78d42b7aa9b912379b38a8 /apps/workers/tidyAssetsWorker.ts
parent10070c1752b5efcbfdf351454de06fbbbe9fb0b6 (diff)
downloadkarakeep-f8bed574ae11a29c9c59f7d96721805188a507db.tar.zst
fix: Only update bookmark tagging/crawling status when worker is out of retries
Diffstat (limited to 'apps/workers/tidyAssetsWorker.ts')
-rw-r--r--apps/workers/tidyAssetsWorker.ts6
1 files changed, 3 insertions, 3 deletions
diff --git a/apps/workers/tidyAssetsWorker.ts b/apps/workers/tidyAssetsWorker.ts
index c70736f2..bea0b7d9 100644
--- a/apps/workers/tidyAssetsWorker.ts
+++ b/apps/workers/tidyAssetsWorker.ts
@@ -19,12 +19,12 @@ export class TidyAssetsWorker {
{
run: runTidyAssets,
onComplete: (job) => {
- const jobId = job?.id ?? "unknown";
+ const jobId = job.id;
logger.info(`[tidyAssets][${jobId}] Completed successfully`);
return Promise.resolve();
},
onError: (job) => {
- const jobId = job?.id ?? "unknown";
+ const jobId = job.id;
logger.error(
`[tidyAssets][${jobId}] tidy assets job failed: ${job.error}\n${job.error.stack}`,
);
@@ -86,7 +86,7 @@ async function handleAsset(
}
async function runTidyAssets(job: DequeuedJob<ZTidyAssetsRequest>) {
- const jobId = job.id ?? "unknown";
+ const jobId = job.id;
const request = zTidyAssetsRequestSchema.safeParse(job.data);
if (!request.success) {