diff options
Diffstat (limited to 'server/lib/schedulers')
-rw-r--r-- | server/lib/schedulers/actor-follow-scheduler.ts | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/server/lib/schedulers/actor-follow-scheduler.ts b/server/lib/schedulers/actor-follow-scheduler.ts index 1b80316e9..a5a377573 100644 --- a/server/lib/schedulers/actor-follow-scheduler.ts +++ b/server/lib/schedulers/actor-follow-scheduler.ts | |||
@@ -2,7 +2,7 @@ import { isTestInstance } from '../../helpers/core-utils' | |||
2 | import { logger } from '../../helpers/logger' | 2 | import { logger } from '../../helpers/logger' |
3 | import { ACTOR_FOLLOW_SCORE, SCHEDULER_INTERVALS_MS } from '../../initializers/constants' | 3 | import { ACTOR_FOLLOW_SCORE, SCHEDULER_INTERVALS_MS } from '../../initializers/constants' |
4 | import { ActorFollowModel } from '../../models/actor/actor-follow' | 4 | import { ActorFollowModel } from '../../models/actor/actor-follow' |
5 | import { ActorFollowScoreCache } from '../files-cache' | 5 | import { ActorFollowHealthCache } from '../actor-follow-health-cache' |
6 | import { AbstractScheduler } from './abstract-scheduler' | 6 | import { AbstractScheduler } from './abstract-scheduler' |
7 | 7 | ||
8 | export class ActorFollowScheduler extends AbstractScheduler { | 8 | export class ActorFollowScheduler extends AbstractScheduler { |
@@ -22,13 +22,13 @@ export class ActorFollowScheduler extends AbstractScheduler { | |||
22 | } | 22 | } |
23 | 23 | ||
24 | private async processPendingScores () { | 24 | private async processPendingScores () { |
25 | const pendingScores = ActorFollowScoreCache.Instance.getPendingFollowsScore() | 25 | const pendingScores = ActorFollowHealthCache.Instance.getPendingFollowsScore() |
26 | const badServerIds = ActorFollowScoreCache.Instance.getBadFollowingServerIds() | 26 | const badServerIds = ActorFollowHealthCache.Instance.getBadFollowingServerIds() |
27 | const goodServerIds = ActorFollowScoreCache.Instance.getGoodFollowingServerIds() | 27 | const goodServerIds = ActorFollowHealthCache.Instance.getGoodFollowingServerIds() |
28 | 28 | ||
29 | ActorFollowScoreCache.Instance.clearPendingFollowsScore() | 29 | ActorFollowHealthCache.Instance.clearPendingFollowsScore() |
30 | ActorFollowScoreCache.Instance.clearBadFollowingServerIds() | 30 | ActorFollowHealthCache.Instance.clearBadFollowingServerIds() |
31 | ActorFollowScoreCache.Instance.clearGoodFollowingServerIds() | 31 | ActorFollowHealthCache.Instance.clearGoodFollowingServerIds() |
32 | 32 | ||
33 | for (const inbox of Object.keys(pendingScores)) { | 33 | for (const inbox of Object.keys(pendingScores)) { |
34 | await ActorFollowModel.updateScore(inbox, pendingScores[inbox]) | 34 | await ActorFollowModel.updateScore(inbox, pendingScores[inbox]) |