aboutsummaryrefslogtreecommitdiffhomepage
path: root/server
diff options
context:
space:
mode:
Diffstat (limited to 'server')
-rw-r--r--server/server/lib/runners/job-handlers/abstract-job-handler.ts4
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
213 runnerJob.resetToPending() 213 runnerJob.resetToPending()
214 214
215 await saveInTransactionWithRetries(runnerJob) 215 await saveInTransactionWithRetries(runnerJob)
216
217 PeerTubeSocket.Instance.sendAvailableJobsPingToRunners()
216 } 218 }
217 219
218 protected setAbortState (runnerJob: MRunnerJob) { 220 protected setAbortState (runnerJob: MRunnerJob) {
@@ -259,6 +261,8 @@ export abstract class AbstractJobHandler <C, U extends RunnerJobUpdatePayload, S
259 261
260 await this.error({ runnerJob: child, message: 'Parent error', fromParent: true }) 262 await this.error({ runnerJob: child, message: 'Parent error', fromParent: true })
261 } 263 }
264 } else {
265 PeerTubeSocket.Instance.sendAvailableJobsPingToRunners()
262 } 266 }
263 } 267 }
264 268