From fe1e3535fdd6edf5be0ac9ecb2ea80fb877751b3 Mon Sep 17 00:00:00 2001
From: Chocobozzz <me@florianbigard.com>
Date: Mon, 28 Aug 2023 16:58:21 +0200
Subject: [PATCH] Ping runners on job abort/error

---
 .../server/lib/runners/job-handlers/abstract-job-handler.ts   | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/server/server/lib/runners/job-handlers/abstract-job-handler.ts b/server/server/lib/runners/job-handlers/abstract-job-handler.ts
index b7e9a0a9d..9a2e2584c 100644
--- a/server/server/lib/runners/job-handlers/abstract-job-handler.ts
+++ b/server/server/lib/runners/job-handlers/abstract-job-handler.ts
@@ -213,6 +213,8 @@ export abstract class AbstractJobHandler <C, U extends RunnerJobUpdatePayload, S
     runnerJob.resetToPending()
 
     await saveInTransactionWithRetries(runnerJob)
+
+    PeerTubeSocket.Instance.sendAvailableJobsPingToRunners()
   }
 
   protected setAbortState (runnerJob: MRunnerJob) {
@@ -259,6 +261,8 @@ export abstract class AbstractJobHandler <C, U extends RunnerJobUpdatePayload, S
 
         await this.error({ runnerJob: child, message: 'Parent error', fromParent: true })
       }
+    } else {
+      PeerTubeSocket.Instance.sendAvailableJobsPingToRunners()
     }
   }