Upping river chunk size to decrease latency.

This commit is contained in:
Samuel Clay 2022-06-27 12:33:36 -04:00
parent 7991c9da26
commit 4081b7b278

View file

@ -150,7 +150,7 @@ class UserSubscription(models.Model):
oldest_manual_unread = r.zrevrange(user_unread_stories_feed_key, -1, -1, withscores=True)
manual_unread_feed_oldest_date[us.feed_id] = int(oldest_manual_unread[0][1])
for feed_id_group in chunks(feed_ids, 20):
for feed_id_group in chunks(feed_ids, 100):
pipeline = r.pipeline()
for feed_id in feed_id_group:
stories_key = 'F:%s' % feed_id