diff options
Diffstat (limited to 'server/lib/job-queue')
-rw-r--r-- | server/lib/job-queue/handlers/transcoding-job-builder.ts | 3 | ||||
-rw-r--r-- | server/lib/job-queue/handlers/video-import.ts | 7 | ||||
-rw-r--r-- | server/lib/job-queue/handlers/video-studio-edition.ts | 2 |
3 files changed, 7 insertions, 5 deletions
diff --git a/server/lib/job-queue/handlers/transcoding-job-builder.ts b/server/lib/job-queue/handlers/transcoding-job-builder.ts index cb45337df..8621b109f 100644 --- a/server/lib/job-queue/handlers/transcoding-job-builder.ts +++ b/server/lib/job-queue/handlers/transcoding-job-builder.ts | |||
@@ -23,7 +23,8 @@ async function processTranscodingJobBuilder (job: Job) { | |||
23 | 23 | ||
24 | video, | 24 | video, |
25 | videoFile, | 25 | videoFile, |
26 | user | 26 | user, |
27 | videoFileAlreadyLocked: false | ||
27 | }) | 28 | }) |
28 | } | 29 | } |
29 | 30 | ||
diff --git a/server/lib/job-queue/handlers/video-import.ts b/server/lib/job-queue/handlers/video-import.ts index 2a063282c..cdd362f6e 100644 --- a/server/lib/job-queue/handlers/video-import.ts +++ b/server/lib/job-queue/handlers/video-import.ts | |||
@@ -242,7 +242,7 @@ async function processFile (downloader: () => Promise<string>, videoImport: MVid | |||
242 | }) | 242 | }) |
243 | }) | 243 | }) |
244 | 244 | ||
245 | await afterImportSuccess({ videoImport: videoImportUpdated, video, videoFile, user: videoImport.User }) | 245 | await afterImportSuccess({ videoImport: videoImportUpdated, video, videoFile, user: videoImport.User, videoFileAlreadyLocked: true }) |
246 | } finally { | 246 | } finally { |
247 | videoFileLockReleaser() | 247 | videoFileLockReleaser() |
248 | } | 248 | } |
@@ -292,8 +292,9 @@ async function afterImportSuccess (options: { | |||
292 | video: MVideoFullLight | 292 | video: MVideoFullLight |
293 | videoFile: MVideoFile | 293 | videoFile: MVideoFile |
294 | user: MUserId | 294 | user: MUserId |
295 | videoFileAlreadyLocked: boolean | ||
295 | }) { | 296 | }) { |
296 | const { video, videoFile, videoImport, user } = options | 297 | const { video, videoFile, videoImport, user, videoFileAlreadyLocked } = options |
297 | 298 | ||
298 | Notifier.Instance.notifyOnFinishedVideoImport({ videoImport: Object.assign(videoImport, { Video: video }), success: true }) | 299 | Notifier.Instance.notifyOnFinishedVideoImport({ videoImport: Object.assign(videoImport, { Video: video }), success: true }) |
299 | 300 | ||
@@ -313,7 +314,7 @@ async function afterImportSuccess (options: { | |||
313 | } | 314 | } |
314 | 315 | ||
315 | if (video.state === VideoState.TO_TRANSCODE) { // Create transcoding jobs? | 316 | if (video.state === VideoState.TO_TRANSCODE) { // Create transcoding jobs? |
316 | await createOptimizeOrMergeAudioJobs({ video, videoFile, isNewVideo: true, user }) | 317 | await createOptimizeOrMergeAudioJobs({ video, videoFile, isNewVideo: true, user, videoFileAlreadyLocked }) |
317 | } | 318 | } |
318 | } | 319 | } |
319 | 320 | ||
diff --git a/server/lib/job-queue/handlers/video-studio-edition.ts b/server/lib/job-queue/handlers/video-studio-edition.ts index 991d11ef1..fbb55a388 100644 --- a/server/lib/job-queue/handlers/video-studio-edition.ts +++ b/server/lib/job-queue/handlers/video-studio-edition.ts | |||
@@ -95,7 +95,7 @@ async function processVideoStudioEdition (job: Job) { | |||
95 | 95 | ||
96 | const user = await UserModel.loadByVideoId(video.id) | 96 | const user = await UserModel.loadByVideoId(video.id) |
97 | 97 | ||
98 | await createOptimizeOrMergeAudioJobs({ video, videoFile: newFile, isNewVideo: false, user }) | 98 | await createOptimizeOrMergeAudioJobs({ video, videoFile: newFile, isNewVideo: false, user, videoFileAlreadyLocked: false }) |
99 | } | 99 | } |
100 | 100 | ||
101 | // --------------------------------------------------------------------------- | 101 | // --------------------------------------------------------------------------- |