Removes delete redis action

This commit is contained in:
Mouse Reeve 2021-08-03 10:44:48 -07:00
parent be044bce0d
commit 19acfeeb72

View file

@ -65,10 +65,6 @@ class RedisStore(ABC):
pipeline = r.pipeline() pipeline = r.pipeline()
queryset = self.get_objects_for_store(store) queryset = self.get_objects_for_store(store)
# first, remove everything currently in it
pipeline.delete(store)
# now, add everything back
for obj in queryset[: self.max_length]: for obj in queryset[: self.max_length]:
pipeline.zadd(store, self.get_value(obj)) pipeline.zadd(store, self.get_value(obj))