diff --git a/setup.py b/setup.py index d1e6f83..6bb0540 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ def read(fname): return open(os.path.join(os.path.dirname(__file__), fname)).read() args = { "name":"data-transport", - "version":"1.3.0", + "version":"1.3.2", "author":"The Phi Technology LLC","author_email":"info@the-phi.com", "license":"MIT", "packages":["transport"]} diff --git a/transport/mongo.py b/transport/mongo.py index 99cca05..f206482 100644 --- a/transport/mongo.py +++ b/transport/mongo.py @@ -65,6 +65,8 @@ class MongoReader(Mongo,Reader): out = self.db.command(cmd) #@TODO: consider using a yield (generator) works wonders while True : + if 'values' in out : + r += out['values'] if 'cursor' in out : key = 'firstBatch' if 'firstBatch' in out['cursor'] else 'nextBatch' else: