diff options
| author | Chocobozzz <me@florianbigard.com> | 2022-03-22 14:35:04 +0100 |
|---|---|---|
| committer | Chocobozzz <me@florianbigard.com> | 2022-03-22 16:25:14 +0100 |
| commit | 1808a1f8e4b7b102823492a2007a46929aebf189 (patch) | |
| tree | a345140ec9a7a20c222ace3cda18ac999277c8c3 /server/lib/job-queue/handlers/video-transcoding.ts | |
| parent | 348c2ce3ff3fe2f25a31f08bfb36c88723a0ce46 (diff) | |
| download | PeerTube-1808a1f8e4b7b102823492a2007a46929aebf189.tar.gz PeerTube-1808a1f8e4b7b102823492a2007a46929aebf189.tar.zst PeerTube-1808a1f8e4b7b102823492a2007a46929aebf189.zip | |
Add video edition finished notification
Diffstat (limited to 'server/lib/job-queue/handlers/video-transcoding.ts')
| -rw-r--r-- | server/lib/job-queue/handlers/video-transcoding.ts | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/server/lib/job-queue/handlers/video-transcoding.ts b/server/lib/job-queue/handlers/video-transcoding.ts index 512979734..95ee6b384 100644 --- a/server/lib/job-queue/handlers/video-transcoding.ts +++ b/server/lib/job-queue/handlers/video-transcoding.ts | |||
| @@ -168,7 +168,7 @@ async function onHlsPlaylistGeneration (video: MVideoFullLight, user: MUser, pay | |||
| 168 | } | 168 | } |
| 169 | 169 | ||
| 170 | await VideoJobInfoModel.decrease(video.uuid, 'pendingTranscode') | 170 | await VideoJobInfoModel.decrease(video.uuid, 'pendingTranscode') |
| 171 | await retryTransactionWrapper(moveToNextState, video, payload.isNewVideo) | 171 | await retryTransactionWrapper(moveToNextState, { video, isNewVideo: payload.isNewVideo }) |
| 172 | } | 172 | } |
| 173 | 173 | ||
| 174 | async function onVideoFirstWebTorrentTranscoding ( | 174 | async function onVideoFirstWebTorrentTranscoding ( |
| @@ -210,7 +210,7 @@ async function onVideoFirstWebTorrentTranscoding ( | |||
| 210 | 210 | ||
| 211 | // Move to next state if there are no other resolutions to generate | 211 | // Move to next state if there are no other resolutions to generate |
| 212 | if (!hasHls && !hasNewResolutions) { | 212 | if (!hasHls && !hasNewResolutions) { |
| 213 | await retryTransactionWrapper(moveToNextState, videoDatabase, payload.isNewVideo) | 213 | await retryTransactionWrapper(moveToNextState, { video: videoDatabase, isNewVideo: payload.isNewVideo }) |
| 214 | } | 214 | } |
| 215 | } | 215 | } |
| 216 | 216 | ||
| @@ -225,7 +225,7 @@ async function onNewWebTorrentFileResolution ( | |||
| 225 | 225 | ||
| 226 | await VideoJobInfoModel.decrease(video.uuid, 'pendingTranscode') | 226 | await VideoJobInfoModel.decrease(video.uuid, 'pendingTranscode') |
| 227 | 227 | ||
| 228 | await retryTransactionWrapper(moveToNextState, video, payload.isNewVideo) | 228 | await retryTransactionWrapper(moveToNextState, { video, isNewVideo: payload.isNewVideo }) |
| 229 | } | 229 | } |
| 230 | 230 | ||
| 231 | // --------------------------------------------------------------------------- | 231 | // --------------------------------------------------------------------------- |