From 6f8019f5829189deea34590e9c09667631abe5d3 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Mon, 16 Jun 2025 11:30:49 -0500 Subject: [PATCH 1/2] bug fix --- info/__init__.py | 2 +- transport/warehouse/iceberg.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/info/__init__.py b/info/__init__.py index 3e6c1ca..19b0e10 100644 --- a/info/__init__.py +++ b/info/__init__.py @@ -1,6 +1,6 @@ __app_name__ = 'data-transport' __author__ = 'The Phi Technology' -__version__= '2.2.14' +__version__= '2.2.16' __email__ = "info@the-phi.com" __edition__= 'community' __license__=f""" diff --git a/transport/warehouse/iceberg.py b/transport/warehouse/iceberg.py index 4e73c62..3def181 100644 --- a/transport/warehouse/iceberg.py +++ b/transport/warehouse/iceberg.py @@ -74,7 +74,7 @@ class Iceberg : """ sql query/command to run against apache iceberg """ - return self._session.sql(_query) + return self._session.sql(_query).toPandas() def has (self,**_args): try: _prefix = self._getPrefix(**_args) From e035f5eba0812006bab16e4bb117fef387775927 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Mon, 23 Jun 2025 04:08:14 -0500 Subject: [PATCH 2/2] windows bug fix, environment variable --- info/__init__.py | 2 +- transport/iowrapper.py | 19 +------------------ transport/registry.py | 2 +- 3 files changed, 3 insertions(+), 20 deletions(-) diff --git a/info/__init__.py b/info/__init__.py index 19b0e10..ef03a5b 100644 --- a/info/__init__.py +++ b/info/__init__.py @@ -1,6 +1,6 @@ __app_name__ = 'data-transport' __author__ = 'The Phi Technology' -__version__= '2.2.16' +__version__= '2.2.18' __email__ = "info@the-phi.com" __edition__= 'community' __license__=f""" diff --git a/transport/iowrapper.py b/transport/iowrapper.py index 3fc94c7..6fd1196 100644 --- a/transport/iowrapper.py +++ b/transport/iowrapper.py @@ -26,24 +26,7 @@ class IO: self._ixloader = plugin_ix.Loader (registry=plugin_ix.Registry(folder=transport.registry.REGISTRY_PATH)) if plugins : self.init_plugins(plugins) - # for _ref in plugins : - # self._ixloader.set(_ref) - # if plugins : - # self._init_plugins(plugins) - # else: - # self._plugins = None - - # def _init_plugins(self,_args): - # """ - # This function will load pipelined functions as a plugin loader - # """ - # if 'path' in _args and 'names' in _args : - # self._plugins = PluginLoader(**_args) - # else: - # self._plugins = PluginLoader() - # [self._plugins.set(_pointer) for _pointer in _args] - # - # @TODO: We should have a way to log what plugins are loaded and ready to use + def meta (self,**_args): if hasattr(self._agent,'meta') : return self._agent.meta(**_args) diff --git a/transport/registry.py b/transport/registry.py index 71909f6..8853069 100644 --- a/transport/registry.py +++ b/transport/registry.py @@ -13,7 +13,7 @@ This class manages data from the registry and allows (read only) @TODO: add property to the DATA attribute """ -REGISTRY_PATH=os.sep.join([os.environ['HOME'],'.data-transport']) +REGISTRY_PATH=os.sep.join([os.environ.get('HOME','USERPROFILE'),'.data-transport']) # # This path can be overriden by an environment variable ... #