minor bug fix

This commit is contained in:
Steve Nyemba 2022-02-10 12:21:40 -06:00
parent 705a39acbe
commit d8f6b84951
1 changed files with 1 additions and 1 deletions

View File

@ -182,7 +182,7 @@ class Reader(Worker):
try:
self.reader = transport.factory.instance(**self._info) ;
print (self._info)
# self.rows = self.reader.read(mongo=self.pipeline)
self.rows = self.reader.read(**self.pipeline)