diff options
author | Chocobozzz <me@florianbigard.com> | 2023-07-28 16:22:27 +0200 |
---|---|---|
committer | Chocobozzz <me@florianbigard.com> | 2023-07-28 16:22:27 +0200 |
commit | ce8d0b5aaeb968d774ab2390461eec687d4730f4 (patch) | |
tree | 45fb92571c42481c3a5dd76da9261eaf1e3fcebf /server/lib/schedulers | |
parent | b203a25e1f6c4b9b3f4495349f42c2ef51e60523 (diff) | |
download | PeerTube-ce8d0b5aaeb968d774ab2390461eec687d4730f4.tar.gz PeerTube-ce8d0b5aaeb968d774ab2390461eec687d4730f4.tar.zst PeerTube-ce8d0b5aaeb968d774ab2390461eec687d4730f4.zip |
Remove deprecated scheduler
Diffstat (limited to 'server/lib/schedulers')
-rw-r--r-- | server/lib/schedulers/remove-old-jobs-scheduler.ts | 28 |
1 files changed, 0 insertions, 28 deletions
diff --git a/server/lib/schedulers/remove-old-jobs-scheduler.ts b/server/lib/schedulers/remove-old-jobs-scheduler.ts deleted file mode 100644 index 6b05ea144..000000000 --- a/server/lib/schedulers/remove-old-jobs-scheduler.ts +++ /dev/null | |||
@@ -1,28 +0,0 @@ | |||
1 | import { isTestOrDevInstance } from '../../helpers/core-utils' | ||
2 | import { logger } from '../../helpers/logger' | ||
3 | import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants' | ||
4 | import { JobQueue } from '../job-queue' | ||
5 | import { AbstractScheduler } from './abstract-scheduler' | ||
6 | |||
7 | // FIXME: delete this scheduler in a few versions (introduced in 5.0) | ||
8 | // We introduced job removal directly using bullmq option but we still need to delete old jobs | ||
9 | export class RemoveOldJobsScheduler extends AbstractScheduler { | ||
10 | |||
11 | private static instance: AbstractScheduler | ||
12 | |||
13 | protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.REMOVE_OLD_JOBS | ||
14 | |||
15 | private constructor () { | ||
16 | super() | ||
17 | } | ||
18 | |||
19 | protected internalExecute () { | ||
20 | if (!isTestOrDevInstance()) logger.info('Removing old jobs in scheduler.') | ||
21 | |||
22 | return JobQueue.Instance.removeOldJobs() | ||
23 | } | ||
24 | |||
25 | static get Instance () { | ||
26 | return this.instance || (this.instance = new this()) | ||
27 | } | ||
28 | } | ||