const VIDEO_IMPORT_TIMEOUT = Math.floor(JOB_TTL['video-import'] * 0.9)
const RUNNER_JOBS = {
- MAX_FAILURES: 5
+ MAX_FAILURES: 5,
+ LAST_CONTACT_UPDATE_INTERVAL: 30000
}
// ---------------------------------------------------------------------------
VIDEO_LIVE.SEGMENT_TIME_SECONDS.DEFAULT_LATENCY = 2
VIDEO_LIVE.SEGMENT_TIME_SECONDS.SMALL_LATENCY = 1
VIDEO_LIVE.EDGE_LIVE_DELAY_SEGMENTS_NOTIFICATION = 1
+
+ RUNNER_JOBS.LAST_CONTACT_UPDATE_INTERVAL = 2000
}
}
import { logger, loggerTagsFactory } from '@server/helpers/logger'
import { sequelizeTypescript } from '@server/initializers/database'
import { MRunner } from '@server/types/models/runners'
+import { RUNNER_JOBS } from '@server/initializers/constants'
const lTags = loggerTagsFactory('runner')
const now = new Date()
// Don't update last runner contact too often
- if (now.getTime() - runner.lastContact.getTime() < 30000) return
+ if (now.getTime() - runner.lastContact.getTime() < RUNNER_JOBS.LAST_CONTACT_UPDATE_INTERVAL) return
if (updatingRunner.has(runner.id)) return
updatingRunner.add(runner.id)
// ---------------------------------------------------------------
before(async function () {
- this.timeout(30000)
+ this.timeout(120000)
server = await createSingleServer(1)
let emails: object[] = []
before(async function () {
- this.timeout(50000)
+ this.timeout(120000)
const res = await prepareNotificationsTest(3)
emails = res.emails
let baseParams: CheckerBaseParams
before(async function () {
- this.timeout(50000)
+ this.timeout(120000)
const res = await prepareNotificationsTest(1)
let command: SearchCommand
before(async function () {
- this.timeout(240000)
+ this.timeout(360000)
const servers = await Promise.all([
createSingleServer(1),