Add more log when refusing to process another job

This commit is contained in:
Chocobozzz 2024-11-07 16:50:57 +01:00
parent 20dbdaaeea
commit 6e2f86e1b3
No known key found for this signature in database
GPG Key ID: 583A612D890159BE
1 changed files with 6 additions and 1 deletions

View File

@ -259,7 +259,12 @@ export class RunnerServer {
} }
private async tryToExecuteJobAsync (server: PeerTubeServer, jobToAccept: { uuid: string }) { private async tryToExecuteJobAsync (server: PeerTubeServer, jobToAccept: { uuid: string }) {
if (!this.canProcessMoreJobs()) return if (!this.canProcessMoreJobs()) {
logger.info(
`Do not process more jobs (processing ${this.processingJobs.length} / ${ConfigManager.Instance.getConfig().jobs.concurrency})`
)
return
}
const { job } = await server.runnerJobs.accept({ runnerToken: server.runnerToken, jobUUID: jobToAccept.uuid }) const { job } = await server.runnerJobs.accept({ runnerToken: server.runnerToken, jobUUID: jobToAccept.uuid })