Commit b2cead60 authored by ale's avatar ale

deserialize values returned from get_connections()

parent ac81d393
......@@ -18,7 +18,8 @@ class Accounting(object):
local_pipe.execute()
def get_connections(self, cn, n=0):
return self._aggr_db.lrange('connections:%s' % cn, 0, (n - 1))
return (json.loads(x) for x in
self._aggr_db.lrange('connections:%s' % cn, 0, (n - 1)))
def aggregate(self, cn):
conns = []
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment