diff options
Diffstat (limited to 'server')
-rw-r--r-- | server/server/lib/runners/job-handlers/abstract-job-handler.ts | 4 |
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 | ||