import { isTestInstance } from '../../helpers/core-utils' ; import { logger } from '../../helpers/logger' ; import { JobQueue } from '../job-queue' ; import { AbstractScheduler } from './abstract-scheduler' ; import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants' ; export class RemoveOldJobsScheduler extends AbstractScheduler { private static instance : AbstractScheduler ; protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS . REMOVE_OLD_JOBS ; private constructor ( ) { super ( ) ; } protected internalExecute ( ) { if ( ! isTestInstance ( ) ) logger . info ( 'Removing old jobs in scheduler.' ) ; return JobQueue . Instance . removeOldJobs ( ) ; } static get Instance ( ) { return this . instance || ( this . instance = new this ( ) ) ; } }