aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/jobs/job-scheduler.ts
diff options
context:
space:
mode:
authorChocobozzz <florian.bigard@gmail.com>2017-11-15 16:28:35 +0100
committerChocobozzz <florian.bigard@gmail.com>2017-11-27 19:40:52 +0100
commit8e10cf1a5a438a00e5f7e0691cb830769867cffc (patch)
tree23c0aeb43d7fb05b2d280c37b4334c2f320b647e /server/lib/jobs/job-scheduler.ts
parent8e13fa7d09e9925b4559cbba6c5d72c5ff1bd391 (diff)
downloadPeerTube-8e10cf1a5a438a00e5f7e0691cb830769867cffc.tar.gz
PeerTube-8e10cf1a5a438a00e5f7e0691cb830769867cffc.tar.zst
PeerTube-8e10cf1a5a438a00e5f7e0691cb830769867cffc.zip
Fix video upload and videos list
Diffstat (limited to 'server/lib/jobs/job-scheduler.ts')
-rw-r--r--server/lib/jobs/job-scheduler.ts4
1 files changed, 2 insertions, 2 deletions
diff --git a/server/lib/jobs/job-scheduler.ts b/server/lib/jobs/job-scheduler.ts
index b25bb7ab3..73c440279 100644
--- a/server/lib/jobs/job-scheduler.ts
+++ b/server/lib/jobs/job-scheduler.ts
@@ -9,7 +9,7 @@ import { error } from 'util'
9export interface JobHandler<P, T> { 9export interface JobHandler<P, T> {
10 process (data: object, jobId: number): Promise<T> 10 process (data: object, jobId: number): Promise<T>
11 onError (err: Error, jobId: number) 11 onError (err: Error, jobId: number)
12 onSuccess (jobId: number, jobResult: T, jobScheduler: JobScheduler<P, T>) 12 onSuccess (jobId: number, jobResult: T, jobScheduler: JobScheduler<P, T>): Promise<any>
13} 13}
14type JobQueueCallback = (err: Error) => void 14type JobQueueCallback = (err: Error) => void
15 15
@@ -127,7 +127,7 @@ class JobScheduler<P, T> {
127 127
128 try { 128 try {
129 await job.save() 129 await job.save()
130 jobHandler.onSuccess(job.id, jobResult, this) 130 await jobHandler.onSuccess(job.id, jobResult, this)
131 } catch (err) { 131 } catch (err) {
132 this.cannotSaveJobError(err) 132 this.cannotSaveJobError(err)
133 } 133 }