diff --git a/server/core/lib/runners/job-handlers/abstract-job-handler.ts b/server/core/lib/runners/job-handlers/abstract-job-handler.ts index 9a2e2584c..1cc8f236c 100644 --- a/server/core/lib/runners/job-handlers/abstract-job-handler.ts +++ b/server/core/lib/runners/job-handlers/abstract-job-handler.ts @@ -86,15 +86,13 @@ export abstract class AbstractJobHandler { - return runnerJob.save({ transaction }) - }) + await saveInTransactionWithRetries(runnerJob) if (runnerJob.state === RunnerJobState.PENDING) { PeerTubeSocket.Instance.sendAvailableJobsPingToRunners() } - return job + return runnerJob } // ---------------------------------------------------------------------------