From 6e2f86e1b31d64ea7138573a3a096743a41cf6ea Mon Sep 17 00:00:00 2001
From: Chocobozzz <me@florianbigard.com>
Date: Thu, 7 Nov 2024 16:50:57 +0100
Subject: [PATCH] Add more log when refusing to process another job
---
apps/peertube-runner/src/server/server.ts | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/apps/peertube-runner/src/server/server.ts b/apps/peertube-runner/src/server/server.ts
index 410015a91..56239d6f7 100644
--- a/apps/peertube-runner/src/server/server.ts
+++ b/apps/peertube-runner/src/server/server.ts
@@ -259,7 +259,12 @@ export class RunnerServer {
}
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 })