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

Also add stall job check for studio

Browse source
This commit is contained in:
Chocobozzz 2025-07-29 09:29:05 +02:00
parent cdb861a26a
commit 17247f205f
No known key found for this signature in database
GPG key ID: 583A612D890159BE
4 changed files with 10 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'
studio: '2 minutes'
transcription: '2 minutes' transcription: '2 minutes'
thumbnails: thumbnails:

2
config/production.yaml.example
View file

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

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

@ -443,6 +443,7 @@ const CONFIG = {
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')),
STUDIO: parseDurationToMs(config.get<string>('remote_runners.stalled_jobs.studio')),
TRANSCRIPTION: parseDurationToMs(config.get<string>('remote_runners.stalled_jobs.transcription')) TRANSCRIPTION: parseDurationToMs(config.get<string>('remote_runners.stalled_jobs.transcription'))
} }
}, },

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

@ -8,7 +8,6 @@ import { AbstractScheduler } from './abstract-scheduler.js'
const lTags = loggerTagsFactory('runner') const lTags = loggerTagsFactory('runner')
export class RunnerJobWatchDogScheduler extends AbstractScheduler { export class RunnerJobWatchDogScheduler extends AbstractScheduler {
private static instance: AbstractScheduler private static instance: AbstractScheduler
protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.RUNNER_JOB_WATCH_DOG protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.RUNNER_JOB_WATCH_DOG
@ -33,7 +32,12 @@ export class RunnerJobWatchDogScheduler extends AbstractScheduler {
types: [ 'video-transcription' ] types: [ 'video-transcription' ]
}) })
for (const stalled of [ ...vodStalledJobs, ...liveStalledJobs, ...transcriptionStalledJobs ]) { const studioStalledJobs = await RunnerJobModel.listStalledJobs({
staleTimeMS: CONFIG.REMOTE_RUNNERS.STALLED_JOBS.STUDIO,
types: [ 'video-studio-transcoding' ]
})
for (const stalled of [ ...vodStalledJobs, ...liveStalledJobs, ...transcriptionStalledJobs, ...studioStalledJobs ]) {
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)