diff options
| author | Chocobozzz <me@florianbigard.com> | 2018-12-20 14:31:11 +0100 |
|---|---|---|
| committer | Chocobozzz <me@florianbigard.com> | 2018-12-20 14:31:11 +0100 |
| commit | 2f5c6b2fc6e60502c2a8df4dc9029c1d87ebe30b (patch) | |
| tree | 9b83f018403c30421c1b3ca4439c4dddc5077881 /server/lib/job-queue/job-queue.ts | |
| parent | 4707f410ae44b55e17e1758693dd21cff03b7ef1 (diff) | |
| download | PeerTube-2f5c6b2fc6e60502c2a8df4dc9029c1d87ebe30b.tar.gz PeerTube-2f5c6b2fc6e60502c2a8df4dc9029c1d87ebe30b.tar.zst PeerTube-2f5c6b2fc6e60502c2a8df4dc9029c1d87ebe30b.zip | |
Optimize actor follow scores modifications
Diffstat (limited to 'server/lib/job-queue/job-queue.ts')
| -rw-r--r-- | server/lib/job-queue/job-queue.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/server/lib/job-queue/job-queue.ts b/server/lib/job-queue/job-queue.ts index e34be7dcd..ba9cbe0d9 100644 --- a/server/lib/job-queue/job-queue.ts +++ b/server/lib/job-queue/job-queue.ts | |||
| @@ -165,10 +165,10 @@ class JobQueue { | |||
| 165 | return total | 165 | return total |
| 166 | } | 166 | } |
| 167 | 167 | ||
| 168 | removeOldJobs () { | 168 | async removeOldJobs () { |
| 169 | for (const key of Object.keys(this.queues)) { | 169 | for (const key of Object.keys(this.queues)) { |
| 170 | const queue = this.queues[key] | 170 | const queue = this.queues[key] |
| 171 | queue.clean(JOB_COMPLETED_LIFETIME, 'completed') | 171 | await queue.clean(JOB_COMPLETED_LIFETIME, 'completed') |
| 172 | } | 172 | } |
| 173 | } | 173 | } |
| 174 | 174 | ||