Skip to content

Commit 3ad6bf5

Browse files
committed
added redis pipe var and fixed pluggable test
1 parent f1c62c2 commit 3ad6bf5

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

splitio/storage/redis.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
MAX_TAGS = 10
1919

2020
class RedisSplitStorageBase(SplitStorage):
21-
"""Redis-based storage base for feature flags."""
21+
"""Redis-based storage base for s."""
2222

2323
_FEATURE_FLAG_KEY = 'SPLITIO.split.{feature_flag_name}'
2424
_FEATURE_FLAG_TILL_KEY = 'SPLITIO.splits.till'
@@ -336,6 +336,7 @@ def __init__(self, redis_client, enable_caching=False, max_age=DEFAULT_MAX_AGE,
336336
self.redis = redis_client
337337
self._enable_caching = enable_caching
338338
self.flag_set_filter = FlagSetsFilter(config_flag_sets)
339+
self._pipe = self.redis.pipeline
339340
if enable_caching:
340341
self._cache = LocalMemoryCache(None, None, max_age)
341342

tests/storage/test_pluggable.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -86,11 +86,9 @@ def get_keys_by_prefix(self, prefix):
8686
def get_many(self, keys):
8787
with self._lock:
8888
returned_keys = []
89-
for key in keys:
90-
if key in self._keys:
89+
for key in self._keys:
90+
if key in keys:
9191
returned_keys.append(self._keys[key])
92-
else:
93-
returned_keys.append(None)
9492
return returned_keys
9593

9694
def add_items(self, key, added_items):

0 commit comments

Comments
 (0)