Steve Nyemba 2 weeks ago
parent
commit
6f8019f582
2 changed files with 2 additions and 2 deletions
  1. 1 1
      info/__init__.py
  2. 1 1
      transport/warehouse/iceberg.py

+ 1 - 1
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"""

+ 1 - 1
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)