aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/job-queue/job-queue.ts
diff options
context:
space:
mode:
Diffstat (limited to 'server/lib/job-queue/job-queue.ts')
-rw-r--r--server/lib/job-queue/job-queue.ts8
1 files changed, 7 insertions, 1 deletions
diff --git a/server/lib/job-queue/job-queue.ts b/server/lib/job-queue/job-queue.ts
index 167b7b168..d3776c3bf 100644
--- a/server/lib/job-queue/job-queue.ts
+++ b/server/lib/job-queue/job-queue.ts
@@ -106,6 +106,8 @@ const jobTypes: JobType[] = [
106 'video-studio-edition' 106 'video-studio-edition'
107] 107]
108 108
109const silentFailure = new Set<JobType>([ 'activitypub-http-unicast' ])
110
109class JobQueue { 111class JobQueue {
110 112
111 private static instance: JobQueue 113 private static instance: JobQueue
@@ -152,7 +154,11 @@ class JobQueue {
152 .catch(err => logger.error('Error in job queue processor %s.', handlerName, { err })) 154 .catch(err => logger.error('Error in job queue processor %s.', handlerName, { err }))
153 155
154 queue.on('failed', (job, err) => { 156 queue.on('failed', (job, err) => {
155 logger.error('Cannot execute job %d in queue %s.', job.id, handlerName, { payload: job.data, err }) 157 const logLevel = silentFailure.has(handlerName)
158 ? 'debug'
159 : 'error'
160
161 logger.log(logLevel, 'Cannot execute job %d in queue %s.', job.id, handlerName, { payload: job.data, err })
156 }) 162 })
157 163
158 queue.on('error', err => { 164 queue.on('error', err => {