From 7ba09309d3e7746d0405240bb8855e3281b284d5 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Sat, 26 Dec 2020 12:20:40 -0600 Subject: [PATCH] bug fix: mongodb commands with values --- setup.py | 2 +- transport/mongo.py | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) 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: