diff --git a/tasks/processJobs.ts b/tasks/processJobs.ts index a2b05de..5df61bb 100644 --- a/tasks/processJobs.ts +++ b/tasks/processJobs.ts @@ -50,7 +50,11 @@ export async function processJobs(): Promise { } if ( err instanceof SdApiError && - (err.statusCode === 0 /* Network error */ || err.statusCode === 404) + ( + err.statusCode === 0 /* Network error */ || + err.statusCode === 404 || + err.statusCode === 401 + ) ) { runningWorkers.delete(worker.name); logger().warning( @@ -59,7 +63,7 @@ export async function processJobs(): Promise { } await job.delete().catch(() => undefined); if (!(err instanceof Grammy.GrammyError) || err.error_code !== 403 /* blocked bot */) { - await jobStore.create(job.value); + await jobStore.create(job.value); } }) .finally(() => busyWorkers.delete(worker.name));