aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/jobs
diff options
context:
space:
mode:
Diffstat (limited to 'server/lib/jobs')
-rw-r--r--server/lib/jobs/handlers/video-transcoder.ts2
-rw-r--r--server/lib/jobs/job-scheduler.ts10
2 files changed, 6 insertions, 6 deletions
diff --git a/server/lib/jobs/handlers/video-transcoder.ts b/server/lib/jobs/handlers/video-transcoder.ts
index e829ca813..eeb2d57b0 100644
--- a/server/lib/jobs/handlers/video-transcoder.ts
+++ b/server/lib/jobs/handlers/video-transcoder.ts
@@ -10,7 +10,7 @@ function process (data: { id: string }) {
10} 10}
11 11
12function onError (err: Error, jobId: number) { 12function onError (err: Error, jobId: number) {
13 logger.error('Error when transcoding video file in job %d.', jobId, { error: err }) 13 logger.error('Error when transcoding video file in job %d.', jobId, err)
14 return Promise.resolve() 14 return Promise.resolve()
15} 15}
16 16
diff --git a/server/lib/jobs/job-scheduler.ts b/server/lib/jobs/job-scheduler.ts
index 248dc7978..2ae732b0f 100644
--- a/server/lib/jobs/job-scheduler.ts
+++ b/server/lib/jobs/job-scheduler.ts
@@ -51,13 +51,13 @@ class JobScheduler {
51 // Optimization: we could use "drain" from queue object 51 // Optimization: we could use "drain" from queue object
52 return setTimeout(next, JOBS_FETCHING_INTERVAL) 52 return setTimeout(next, JOBS_FETCHING_INTERVAL)
53 }) 53 })
54 .catch(err => logger.error('Cannot list pending jobs.', { error: err })) 54 .catch(err => logger.error('Cannot list pending jobs.', err))
55 }, 55 },
56 56
57 err => logger.error('Error in job scheduler queue.', { error: err }) 57 err => logger.error('Error in job scheduler queue.', err)
58 ) 58 )
59 }) 59 })
60 .catch(err => logger.error('Cannot list pending jobs.', { error: err })) 60 .catch(err => logger.error('Cannot list pending jobs.', err))
61 } 61 }
62 62
63 createJob (transaction: Sequelize.Transaction, handlerName: string, handlerInputData: object) { 63 createJob (transaction: Sequelize.Transaction, handlerName: string, handlerInputData: object) {
@@ -95,7 +95,7 @@ class JobScheduler {
95 }, 95 },
96 96
97 err => { 97 err => {
98 logger.error('Error in job handler %s.', job.handlerName, { error: err }) 98 logger.error('Error in job handler %s.', job.handlerName, err)
99 return this.onJobError(jobHandler, job, err) 99 return this.onJobError(jobHandler, job, err)
100 } 100 }
101 ) 101 )
@@ -123,7 +123,7 @@ class JobScheduler {
123 } 123 }
124 124
125 private cannotSaveJobError (err: Error) { 125 private cannotSaveJobError (err: Error) {
126 logger.error('Cannot save new job state.', { error: err }) 126 logger.error('Cannot save new job state.', err)
127 } 127 }
128} 128}
129 129