Uses correct redis remove activity type

This commit is contained in:
Mouse Reeve 2021-04-03 14:56:56 -07:00
parent e51a287cd3
commit 3dee60e9e5

View file

@ -47,7 +47,7 @@ class ActivityStream(ABC):
""" remove a status from all feeds """ """ remove a status from all feeds """
pipeline = r.pipeline() pipeline = r.pipeline()
for user in self.stream_users(status): for user in self.stream_users(status):
pipeline.lrem(self.stream_id(user), -1, status.id) pipeline.zrem(self.stream_id(user), -1, status.id)
pipeline.execute() pipeline.execute()
def add_user_statuses(self, viewer, user): def add_user_statuses(self, viewer, user):