const lTags = lTagsBase(video.uuid, video.url)
+ const fileMutexReleaser = await VideoPathManager.Instance.lockFiles(video.uuid)
+
try {
if (video.VideoFiles) {
logger.debug('Moving %d webtorrent files for video %s.', video.VideoFiles.length, video.uuid, lTags)
}
} catch (err) {
await onMoveToObjectStorageFailure(job, err)
+
+ throw err
+ } finally {
+ fileMutexReleaser()
}
return payload.videoUUID