X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=packages%2Fpeertube-runner%2Fserver%2Fserver.ts;h=087405dfefc7336d8a002a6aecfd275406d9ff49;hb=def4ea4f3824689abd4ea66f5ab6e47d553b7ddd;hp=cb1533dc6db6095bab2bdea88acd4ea5afda1ddc;hpb=fe7019b2323768f7e33890303f95c9a45688ac1d;p=github%2FChocobozzz%2FPeerTube.git diff --git a/packages/peertube-runner/server/server.ts b/packages/peertube-runner/server/server.ts index cb1533dc6..087405dfe 100644 --- 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')) }