mirror of https://github.com/Chocobozzz/PeerTube
Ping runners on job abort/error
parent
6a85ec0480
commit
fe1e3535fd
|
@ -213,6 +213,8 @@ export abstract class AbstractJobHandler <C, U extends RunnerJobUpdatePayload, S
|
||||||
runnerJob.resetToPending()
|
runnerJob.resetToPending()
|
||||||
|
|
||||||
await saveInTransactionWithRetries(runnerJob)
|
await saveInTransactionWithRetries(runnerJob)
|
||||||
|
|
||||||
|
PeerTubeSocket.Instance.sendAvailableJobsPingToRunners()
|
||||||
}
|
}
|
||||||
|
|
||||||
protected setAbortState (runnerJob: MRunnerJob) {
|
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 })
|
await this.error({ runnerJob: child, message: 'Parent error', fromParent: true })
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
PeerTubeSocket.Instance.sendAvailableJobsPingToRunners()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue