import { wait } from '../miscs'
import { PeerTubeServer } from './server'
-async function waitJobs (serversArg: PeerTubeServer[] | PeerTubeServer) {
+async function waitJobs (serversArg: PeerTubeServer[] | PeerTubeServer, skipDelayed = false) {
const pendingJobWait = process.env.NODE_PENDING_JOB_WAIT
? parseInt(process.env.NODE_PENDING_JOB_WAIT, 10)
: 250
if (Array.isArray(serversArg) === false) servers = [ serversArg as PeerTubeServer ]
else servers = serversArg as PeerTubeServer[]
- const states: JobState[] = [ 'waiting', 'active', 'delayed' ]
+ const states: JobState[] = [ 'waiting', 'active' ]
+ if (!skipDelayed) states.push('delayed')
+
const repeatableJobs = [ 'videos-views', 'activitypub-cleaner' ]
let pendingRequests: boolean
// Check if each server has pending request
for (const server of servers) {
for (const state of states) {
- const p = server.jobs.getJobsList({
+ const p = server.jobs.list({
state,
start: 0,
count: 10,