From 80438dc1e2b3507f514e275cffb7ce3ab2fbbc48 Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Fri, 27 May 2022 09:37:25 -0400 Subject: [PATCH] fix median calculation by forcing a limit --- internal/worker/trending.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/worker/trending.go b/internal/worker/trending.go index 3533cea..6e6babb 100644 --- a/internal/worker/trending.go +++ b/internal/worker/trending.go @@ -174,7 +174,7 @@ func (tc *trendingConsumer) Consume(delivery rmq.Delivery) { watcher := watchers[i] rac := tc.reddit.NewAuthenticatedClient(watcher.Account.AccountID, watcher.Account.RefreshToken, watcher.Account.AccessToken) - tps, err := rac.SubredditTop(tc, subreddit.Name, reddit.WithQuery("t", "week"), reddit.WithQuery("show", "all")) + tps, err := rac.SubredditTop(tc, subreddit.Name, reddit.WithQuery("t", "week"), reddit.WithQuery("show", "all"), reddit.WithQuery("limit", "25")) if err != nil { tc.logger.Error("failed to fetch weeks's top posts", zap.Error(err),