diff --git a/notifications_utils/clients/redis/redis_client.py b/notifications_utils/clients/redis/redis_client.py index 1723dd2c1..3404d27e7 100644 --- a/notifications_utils/clients/redis/redis_client.py +++ b/notifications_utils/clients/redis/redis_client.py @@ -156,6 +156,14 @@ class RedisClient: return None + def rpush(self, key, value): + if self.active: + self.redis_store.rpush(key, value) + + def lpop(self, key, value): + if self.active: + self.redis_store.lpop(key, value) + def delete(self, *keys, raise_exception=False): keys = [prepare_value(k) for k in keys] if self.active: