From 17ecdf61ce1d374cc8ba17601b93c9bda08112b2 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Mon, 22 May 2023 13:44:22 +0200 Subject: Force stop remote live transcoding --- packages/peertube-runner/server/process/shared/process-live.ts | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'packages/peertube-runner') diff --git a/packages/peertube-runner/server/process/shared/process-live.ts b/packages/peertube-runner/server/process/shared/process-live.ts index df1b677f0..6edb1f1e9 100644 --- a/packages/peertube-runner/server/process/shared/process-live.ts +++ b/packages/peertube-runner/server/process/shared/process-live.ts @@ -34,6 +34,8 @@ export class ProcessLiveRTMPHLSTranscoding { constructor (private readonly options: ProcessOptions) { this.outputPath = join(ConfigManager.Instance.getTranscodingDirectory(), buildUUID()) + + logger.debug(`Using ${this.outputPath} to process live rtmp hls transcoding job ${options.job.uuid}`) } process () { @@ -289,6 +291,7 @@ export class ProcessLiveRTMPHLSTranscoding { }) } catch (err) { if (currentTry >= 3) throw err + if ((err.res?.body as PeerTubeProblemDocument)?.code === ServerErrorCode.RUNNER_JOB_NOT_IN_PROCESSING_STATE) throw err logger.warn({ err }, 'Will retry update after error') await wait(250) @@ -310,6 +313,8 @@ export class ProcessLiveRTMPHLSTranscoding { // --------------------------------------------------------------------------- private cleanup () { + logger.debug(`Cleaning up job ${this.options.job.uuid}`) + for (const fsWatcher of this.fsWatchers) { fsWatcher.close() .catch(err => logger.error({ err }, 'Cannot close watcher')) -- cgit v1.2.3