aboutsummaryrefslogtreecommitdiffhomepage
path: root/packages/peertube-runner/server/server.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/peertube-runner/server/server.ts')
-rw-r--r--packages/peertube-runner/server/server.ts4
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 @@
1import { ensureDir, readdir, remove } from 'fs-extra' 1import { ensureDir, readdir, remove } from 'fs-extra'
2import { join } from 'path' 2import { join } from 'path'
3import { io, Socket } from 'socket.io-client' 3import { io, Socket } from 'socket.io-client'
4import { pick, wait } from '@shared/core-utils' 4import { pick, shuffle, wait } from '@shared/core-utils'
5import { PeerTubeProblemDocument, ServerErrorCode } from '@shared/models' 5import { PeerTubeProblemDocument, ServerErrorCode } from '@shared/models'
6import { PeerTubeServer as PeerTubeServerCommand } from '@shared/server-commands' 6import { PeerTubeServer as PeerTubeServerCommand } from '@shared/server-commands'
7import { ConfigManager } from '../shared' 7import { 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