From 705a39acbe6e9a33cd411ee1f859de65461be4ae Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Thu, 10 Feb 2022 12:21:04 -0600 Subject: [PATCH] minor bug fix --- healthcareio/export/workers.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/healthcareio/export/workers.py b/healthcareio/export/workers.py index 234cb3c..bd470f4 100644 --- a/healthcareio/export/workers.py +++ b/healthcareio/export/workers.py @@ -182,7 +182,7 @@ class Reader(Worker): try: self.reader = transport.factory.instance(**self._info) ; - # print (self.pipeline) + print (self._info) # self.rows = self.reader.read(mongo=self.pipeline) self.rows = self.reader.read(**self.pipeline) @@ -194,6 +194,7 @@ class Reader(Worker): N = len(self.rows) / self.MAX_ROWS if len(self.rows) > self.MAX_ROWS else 1 N = int(N) # self.rows = rows + _log = {"context":self.name(), "status":1,"info":{"rows":len(self.rows),"table":self.table,"segments":N}} self.rows = np.array_split(self.rows,N)