Another place where redis may be called unnecessarily

This commit is contained in:
Mouse Reeve 2021-04-03 11:07:08 -07:00
parent a913524991
commit 44e87c01ab
1 changed files with 4 additions and 2 deletions

View File

@ -53,9 +53,11 @@ class ActivityStream(ABC):
def add_user_statuses(self, viewer, user): def add_user_statuses(self, viewer, user):
""" add a user's statuses to another user's feed """ """ add a user's statuses to another user's feed """
pipeline = r.pipeline() pipeline = r.pipeline()
for status in user.status_set.all()[: settings.MAX_STREAM_LENGTH]: statuses = user.status_set.all()[: settings.MAX_STREAM_LENGTH]
for status in statuses:
pipeline.zadd(self.stream_id(viewer), self.get_value(status)) pipeline.zadd(self.stream_id(viewer), self.get_value(status))
pipeline.zremrangebyrank(self.stream_id(user), settings.MAX_STREAM_LENGTH, -1) if statuses:
pipeline.zremrangebyrank(self.stream_id(user), settings.MAX_STREAM_LENGTH, -1)
pipeline.execute() pipeline.execute()
def remove_user_statuses(self, viewer, user): def remove_user_statuses(self, viewer, user):