From aaaf64db33d4aa94f7a4c777435a6d4aef92d98d Mon Sep 17 00:00:00 2001
From: Steve Nyemba <nyemba@gmail.com>
Date: Fri, 16 Jun 2023 17:39:02 -0500
Subject: [PATCH] bug fix: versions of sqlalchemy for meta data

---
 transport/sql.py | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/transport/sql.py b/transport/sql.py
index 27d5888..a262c3a 100644
--- a/transport/sql.py
+++ b/transport/sql.py
@@ -106,8 +106,13 @@ class SQLRW :
         try:
             if self._engine :
                 table = _args['table'] if 'table' in _args else self.table
-                _m = sqlalchemy.MetaData(bind=self._engine)
-                _m.reflect()
+                if sqlalchemy.__version__.startswith('1.') :
+                    _m = sqlalchemy.MetaData(bind=self._engine)
+                    _m.reflect()
+                else:
+                    
+                    _m = sqlalchemy.MetaData()                    
+                    _m.reflect(bind=self._engine)
                 schema = [{"name":_attr.name,"type":str(_attr.type)} for _attr in _m.tables[table].columns]
                 #
                 # Some house keeping work
@@ -117,6 +122,7 @@ class SQLRW :
                         _item['type'] = _m[_item['type']]
 
         except Exception as e:
+            print (e)
             pass
         return schema
     def _tablename(self,name) :