

def flush(self, *args):
    if args:
        keys = self.get_keys(args)
        self.redis.delete(*keys)

dataset/ETHPy150Open tschellenbach/Stream-Framework/stream_framework/storage/redis/lists_storage.py RedisListsStorage.flush/original