mirrors/bookwyrm
1
0
Fork 1
mirror of https://github.com/bookwyrm-social/bookwyrm.git synced 2024-06-09 08:49:22 +00:00
Code Issues Projects Releases Wiki Activity

Don't trim stream if max length is unset

Browse source
This commit is contained in:
Mouse Reeve 2021-12-14 11:11:05 -08:00
parent 0012f4464d
commit 65ec626573
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
bookwyrm/redis_store.py
View file

@ -27,7 +27,8 @@ class RedisStore(ABC):
# add the status to the feed
pipeline.zadd(store, value)
# trim the store
pipeline.zremrangebyrank(store, 0, -1 * self.max_length)
if self.max_length:
pipeline.zremrangebyrank(store, 0, -1 * self.max_length)
if not execute:
return pipeline
# and go!
@ -46,7 +47,7 @@ class RedisStore(ABC):
pipeline = r.pipeline()
for obj in objs[: self.max_length]:
pipeline.zadd(store, self.get_value(obj))
if objs:
if objs and self.max_length:
pipeline.zremrangebyrank(store, 0, -1 * self.max_length)
pipeline.execute()
@ -70,7 +71,7 @@ class RedisStore(ABC):
pipeline.zadd(store, self.get_value(obj))
# only trim the store if objects were added
if queryset.exists():
if queryset.exists() and self.max_length:
pipeline.zremrangebyrank(store, 0, -1 * self.max_length)
pipeline.execute()