From 990bb343a425f96b4b9af7bc05248168f4b71f7d Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Tue, 26 Nov 2024 19:18:00 -0600 Subject: [PATCH] bug fixes: read, with source that accepts an sql query --- info/__init__.py | 2 +- transport/iowrapper.py | 8 +++++--- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/info/__init__.py b/info/__init__.py index 99deb57..760b575 100644 --- a/info/__init__.py +++ b/info/__init__.py @@ -1,6 +1,6 @@ __app_name__ = 'data-transport' __author__ = 'The Phi Technology' -__version__= '2.4.7' +__version__= '2.4.8' __email__ = "info@the-phi.com" __license__=f""" Copyright 2010 - 2024, Steve L. Nyemba diff --git a/transport/iowrapper.py b/transport/iowrapper.py index a464fde..04a8531 100644 --- a/transport/iowrapper.py +++ b/transport/iowrapper.py @@ -102,7 +102,7 @@ class IReader(IO): """ def __init__(self,_agent,_plugins=None,_logger=None): super().__init__(_agent,_plugins,_logger) - + self._args = if 'args' in _args else None def _stream (self,_data ): # self.log(action='streaming',object=self._agent._engine.name, input= type(_data).__name__) _shape = [] @@ -120,8 +120,10 @@ class IReader(IO): if 'plugins' in _args : self._init_plugins(_args['plugins']) - - _data = self._agent.read(**_args) + if self._args : + _data = self._agent.read(**self._args) + else: + _data = self._agent.read(**_args) _objectName = '.'.join([self._agent.__class__.__module__,self._agent.__class__.__name__]) if types.GeneratorType == type(_data):