yetangitu/Peertube
1
0
Fork 0
mirror of https://github.com/Chocobozzz/PeerTube.git synced 2025-10-03 01:39:37 +02:00
Code Issues Releases Wiki Activity

Add WatchDog for stalled Transcription jobs

Browse source
This commit is contained in:
Ankit lal 2025-07-22 22:37:51 +05:30 • committed by Chocobozzz
parent 37e13bbcd2
commit cdb861a26a
No known key found for this signature in database
GPG key ID: 583A612D890159BE
3 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

1
config/default.yaml
View file

@ -455,6 +455,7 @@ remote_runners:
stalled_jobs: stalled_jobs:
live: '30 seconds' live: '30 seconds'
vod: '2 minutes' vod: '2 minutes'
transcription: '2 minutes'
thumbnails: thumbnails:
# When automatically generating a thumbnail from the video # When automatically generating a thumbnail from the video

3
server/core/initializers/config.ts
View file

@ -442,7 +442,8 @@ const CONFIG = {
REMOTE_RUNNERS: { REMOTE_RUNNERS: {
STALLED_JOBS: { STALLED_JOBS: {
LIVE: parseDurationToMs(config.get<string>('remote_runners.stalled_jobs.live')), LIVE: parseDurationToMs(config.get<string>('remote_runners.stalled_jobs.live')),
VOD: parseDurationToMs(config.get<string>('remote_runners.stalled_jobs.vod')) VOD: parseDurationToMs(config.get<string>('remote_runners.stalled_jobs.vod')),
TRANSCRIPTION: parseDurationToMs(config.get<string>('remote_runners.stalled_jobs.transcription'))
} }
}, },
THUMBNAILS: { THUMBNAILS: {

7
server/core/lib/schedulers/runner-job-watch-dog-scheduler.ts
View file

@ -28,7 +28,12 @@ export class RunnerJobWatchDogScheduler extends AbstractScheduler {
types: [ 'live-rtmp-hls-transcoding' ] types: [ 'live-rtmp-hls-transcoding' ]
}) })
for (const stalled of [ ...vodStalledJobs, ...liveStalledJobs ]) { const transcriptionStalledJobs = await RunnerJobModel.listStalledJobs({
staleTimeMS: CONFIG.REMOTE_RUNNERS.STALLED_JOBS.TRANSCRIPTION,
types: [ 'video-transcription' ]
})
for (const stalled of [ ...vodStalledJobs, ...liveStalledJobs, ...transcriptionStalledJobs ]) {
logger.info('Abort stalled runner job %s (%s)', stalled.uuid, stalled.type, lTags(stalled.uuid, stalled.type)) logger.info('Abort stalled runner job %s (%s)', stalled.uuid, stalled.type, lTags(stalled.uuid, stalled.type))
const Handler = getRunnerJobHandlerClass(stalled) const Handler = getRunnerJobHandlerClass(stalled)