diff options
| author | Chocobozzz <me@florianbigard.com> | 2022-11-23 17:13:01 +0100 |
|---|---|---|
| committer | Chocobozzz <me@florianbigard.com> | 2022-11-23 17:13:01 +0100 |
| commit | c3b21b68b55fa5cb0ee7a23e4316b5466a0448f0 (patch) | |
| tree | 8b7d0be8a57dc9a57a6f9d3af4a69578f06c0c4c /server/lib/schedulers | |
| parent | 5800f354ccd4845d0b4bc212a0c53a0ff40edf82 (diff) | |
| download | PeerTube-c3b21b68b55fa5cb0ee7a23e4316b5466a0448f0.tar.gz PeerTube-c3b21b68b55fa5cb0ee7a23e4316b5466a0448f0.tar.zst PeerTube-c3b21b68b55fa5cb0ee7a23e4316b5466a0448f0.zip | |
Delete completed/failed jobs directly from bullmq
Diffstat (limited to 'server/lib/schedulers')
| -rw-r--r-- | server/lib/schedulers/remove-old-jobs-scheduler.ts | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/server/lib/schedulers/remove-old-jobs-scheduler.ts b/server/lib/schedulers/remove-old-jobs-scheduler.ts index 879846999..6b05ea144 100644 --- a/server/lib/schedulers/remove-old-jobs-scheduler.ts +++ b/server/lib/schedulers/remove-old-jobs-scheduler.ts | |||
| @@ -4,6 +4,8 @@ import { SCHEDULER_INTERVALS_MS } from '../../initializers/constants' | |||
| 4 | import { JobQueue } from '../job-queue' | 4 | import { JobQueue } from '../job-queue' |
| 5 | import { AbstractScheduler } from './abstract-scheduler' | 5 | import { AbstractScheduler } from './abstract-scheduler' |
| 6 | 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 | ||
| 7 | export class RemoveOldJobsScheduler extends AbstractScheduler { | 9 | export class RemoveOldJobsScheduler extends AbstractScheduler { |
| 8 | 10 | ||
| 9 | private static instance: AbstractScheduler | 11 | private static instance: AbstractScheduler |