Ping runners on job abort/error

1 files changed, 4 insertions, 0 deletions

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()
     }
   }