

def count(self, *args):
    if args:
        keys = self.get_keys(args)
        pipe = self.redis.pipeline()
        for key in keys:
            pipe.llen(key)
        return self._to_result(key.execute())

dataset/ETHPy150Open tschellenbach/Stream-Framework/stream_framework/storage/redis/lists_storage.py RedisListsStorage.count/VarMisuse@57/64 `pipe`->`key`