

def add(self, **kwargs):
    if kwargs:
        pipe = self.redis.pipeline()
        for (list_name, values) in six.iteritems(kwargs):
            if values:
                key = self.get_key(list_name)
                for value in values:
                    pipe.rpush(key, value)
                pipe.ltrim(key, (- self.max_length), (- 1))
        pipe.execute()

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