OpenCloud
/
PeerTube
mirror of https://github.com/Chocobozzz/PeerTube
1
0
Fork 0
Code Issues Releases Wiki Activity

Prefer to wait before processing new jobs

pull/5817/head
Chocobozzz 2023-05-19 10:16:43 +02:00
parent 472170b4f9
commit 296d07c6fe
No known key found for this signature in database
GPG Key ID: 583A612D890159BE
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/peertube-runner/server/server.ts
View File

@ -1,7 +1,7 @@
import { ensureDir, readdir, remove } from 'fs-extra' import { ensureDir, readdir, remove } from 'fs-extra'
import { join } from 'path' import { join } from 'path'
import { io, Socket } from 'socket.io-client' 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 { PeerTubeProblemDocument, ServerErrorCode } from '@shared/models'
import { PeerTubeServer as PeerTubeServerCommand } from '@shared/server-commands' import { PeerTubeServer as PeerTubeServerCommand } from '@shared/server-commands'
import { ConfigManager } from '../shared' import { ConfigManager } from '../shared'
@ -206,6 +206,8 @@ export class RunnerServer {
this.checkingAvailableJobs = false this.checkingAvailableJobs = false
if (hadAvailableJob && this.canProcessMoreJobs()) { if (hadAvailableJob && this.canProcessMoreJobs()) {
await wait(2500)
this.checkAvailableJobs() this.checkAvailableJobs()
.catch(err => logger.error({ err }, 'Cannot check more available jobs')) .catch(err => logger.error({ err }, 'Cannot check more available jobs'))
} }