X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fschedulers%2Fremove-old-jobs-scheduler.ts;h=0e8ad155443a8f87d030d6a1dfbb067620b4b2c0;hb=bf079b7bfd7f0fb75ceb28e333bb4b74d8840dd4;hp=add5677ac03442e629607220714b5c2c71b89d8b;hpb=94a5ff8a4a75d75bb9df542a39ce8769e7a7e6a4;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/schedulers/remove-old-jobs-scheduler.ts b/server/lib/schedulers/remove-old-jobs-scheduler.ts index add5677ac..0e8ad1554 100644 --- a/server/lib/schedulers/remove-old-jobs-scheduler.ts +++ b/server/lib/schedulers/remove-old-jobs-scheduler.ts @@ -1,3 +1,5 @@ +import { isTestInstance } from '../../helpers/core-utils' +import { logger } from '../../helpers/logger' import { JobQueue } from '../job-queue' import { AbstractScheduler } from './abstract-scheduler' @@ -10,6 +12,8 @@ export class RemoveOldJobsScheduler extends AbstractScheduler { } async execute () { + if (!isTestInstance()) logger.info('Removing old jobs (scheduler).') + JobQueue.Instance.removeOldJobs() }