diff options
Diffstat (limited to 'server/lib/job-queue/job-queue.ts')
-rw-r--r-- | server/lib/job-queue/job-queue.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/server/lib/job-queue/job-queue.ts b/server/lib/job-queue/job-queue.ts index 66cced59a..1dc28755e 100644 --- a/server/lib/job-queue/job-queue.ts +++ b/server/lib/job-queue/job-queue.ts | |||
@@ -53,7 +53,7 @@ class JobQueue { | |||
53 | this.jobQueue.setMaxListeners(15) | 53 | this.jobQueue.setMaxListeners(15) |
54 | 54 | ||
55 | this.jobQueue.on('error', err => { | 55 | this.jobQueue.on('error', err => { |
56 | logger.error('Error in job queue.', err) | 56 | logger.error('Error in job queue.', { err }) |
57 | process.exit(-1) | 57 | process.exit(-1) |
58 | }) | 58 | }) |
59 | this.jobQueue.watchStuckJobs(5000) | 59 | this.jobQueue.watchStuckJobs(5000) |
@@ -111,7 +111,7 @@ class JobQueue { | |||
111 | const now = new Date().getTime() | 111 | const now = new Date().getTime() |
112 | kue.Job.rangeByState('complete', 0, -1, 'asc', (err, jobs) => { | 112 | kue.Job.rangeByState('complete', 0, -1, 'asc', (err, jobs) => { |
113 | if (err) { | 113 | if (err) { |
114 | logger.error('Cannot get jobs when removing old jobs.', err) | 114 | logger.error('Cannot get jobs when removing old jobs.', { err }) |
115 | return | 115 | return |
116 | } | 116 | } |
117 | 117 | ||