diff options
Diffstat (limited to 'packages/peertube-runner/server/server.ts')
-rw-r--r-- | packages/peertube-runner/server/server.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/packages/peertube-runner/server/server.ts b/packages/peertube-runner/server/server.ts index e76131c74..5fa86fa1a 100644 --- a/packages/peertube-runner/server/server.ts +++ b/packages/peertube-runner/server/server.ts | |||
@@ -1,7 +1,7 @@ | |||
1 | import { ensureDir, readdir, remove } from 'fs-extra' | 1 | import { ensureDir, readdir, remove } from 'fs-extra' |
2 | import { join } from 'path' | 2 | import { join } from 'path' |
3 | import { io, Socket } from 'socket.io-client' | 3 | import { io, Socket } from 'socket.io-client' |
4 | import { pick, wait } from '@shared/core-utils' | 4 | import { pick, shuffle, wait } from '@shared/core-utils' |
5 | import { PeerTubeProblemDocument, ServerErrorCode } from '@shared/models' | 5 | import { PeerTubeProblemDocument, ServerErrorCode } from '@shared/models' |
6 | import { PeerTubeServer as PeerTubeServerCommand } from '@shared/server-commands' | 6 | import { PeerTubeServer as PeerTubeServerCommand } from '@shared/server-commands' |
7 | import { ConfigManager } from '../shared' | 7 | import { ConfigManager } from '../shared' |
@@ -175,7 +175,7 @@ export class RunnerServer { | |||
175 | 175 | ||
176 | let hadAvailableJob = false | 176 | let hadAvailableJob = false |
177 | 177 | ||
178 | for (const server of this.servers) { | 178 | for (const server of shuffle([ ...this.servers ])) { |
179 | try { | 179 | try { |
180 | logger.info('Checking available jobs on ' + server.url) | 180 | logger.info('Checking available jobs on ' + server.url) |
181 | 181 | ||