Increase old jobs to delete per hour
This commit is contained in:
parent
f7b00376a8
commit
5949eca71f
|
@ -492,8 +492,8 @@ class JobQueue {
|
||||||
async removeOldJobs () {
|
async removeOldJobs () {
|
||||||
for (const key of Object.keys(this.queues)) {
|
for (const key of Object.keys(this.queues)) {
|
||||||
const queue: Queue = this.queues[key]
|
const queue: Queue = this.queues[key]
|
||||||
await queue.clean(parseDurationToMs('7 days'), 100, 'completed')
|
await queue.clean(parseDurationToMs('7 days'), 1000, 'completed')
|
||||||
await queue.clean(parseDurationToMs('7 days'), 100, 'failed')
|
await queue.clean(parseDurationToMs('7 days'), 1000, 'failed')
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue