From 90d4bb8125e80c8060416d4d135ddeaf0a622ede Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Wed, 13 Jun 2018 14:27:40 +0200 Subject: Refractor retry transaction function --- server/lib/job-queue/handlers/video-file.ts | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) (limited to 'server/lib/job-queue/handlers/video-file.ts') diff --git a/server/lib/job-queue/handlers/video-file.ts b/server/lib/job-queue/handlers/video-file.ts index f5ad076a6..a5c6bf300 100644 --- a/server/lib/job-queue/handlers/video-file.ts +++ b/server/lib/job-queue/handlers/video-file.ts @@ -52,19 +52,11 @@ async function processVideoFile (job: kue.Job) { if (payload.resolution) { await video.transcodeOriginalVideofile(payload.resolution, payload.isPortraitMode) - const options = { - arguments: [ video ], - errorMessage: 'Cannot execute onVideoFileTranscoderOrImportSuccess with many retries.' - } - await retryTransactionWrapper(onVideoFileTranscoderOrImportSuccess, options) + await retryTransactionWrapper(onVideoFileTranscoderOrImportSuccess, video) } else { await video.optimizeOriginalVideofile() - const options = { - arguments: [ video, payload.isNewVideo ], - errorMessage: 'Cannot execute onVideoFileOptimizerSuccess with many retries.' - } - await retryTransactionWrapper(onVideoFileOptimizerSuccess, options) + await retryTransactionWrapper(onVideoFileOptimizerSuccess, video, payload.isNewVideo) } return video -- cgit v1.2.3