Prefer to wait before processing new jobs

diff --git a/packages/peertube-runner/server/server.ts b/packages/peertube-runner/server/server.ts
index cb1533dc6db6095bab2bdea88acd4ea5afda1ddc..087405dfefc7336d8a002a6aecfd275406d9ff49 100644 (file)
--- a/packages/peertube-runner/server/server.ts
+++ b/packages/peertube-runner/server/server.ts
@@ -1,7 +1,7 @@
 import { ensureDir, readdir, remove } from 'fs-extra'
 import { join } from 'path'
 import { io, Socket } from 'socket.io-client'
-import { pick } from '@shared/core-utils'
+import { pick, wait } from '@shared/core-utils'
 import { PeerTubeProblemDocument, ServerErrorCode } from '@shared/models'
 import { PeerTubeServer as PeerTubeServerCommand } from '@shared/server-commands'
 import { ConfigManager } from '../shared'
@@ -206,6 +206,8 @@ export class RunnerServer {
     this.checkingAvailableJobs = false
 
     if (hadAvailableJob && this.canProcessMoreJobs()) {
+      await wait(2500)
+
       this.checkAvailableJobs()
         .catch(err => logger.error({ err }, 'Cannot check more available jobs'))
     }