diff options
| author | Mohamed Bassem <me@mbassem.com> | 2024-11-09 14:00:27 +0000 |
|---|---|---|
| committer | Mohamed Bassem <me@mbassem.com> | 2024-11-09 14:00:27 +0000 |
| commit | f8bed574ae11a29c9c59f7d96721805188a507db (patch) | |
| tree | 1f897f80976c1264eb78d42b7aa9b912379b38a8 /apps/workers/tidyAssetsWorker.ts | |
| parent | 10070c1752b5efcbfdf351454de06fbbbe9fb0b6 (diff) | |
| download | karakeep-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.ts | 6 |
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) { |
