From 93537095a4c0ec8f75990dcdda37c08195fb2df7 Mon Sep 17 00:00:00 2001
From: Steve Nyemba <nyemba@gmail.com>
Date: Tue, 28 Jan 2025 18:26:47 -0600
Subject: [PATCH] bug fix: etl & logger

---
 transport/iowrapper.py | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/transport/iowrapper.py b/transport/iowrapper.py
index 1703fc0..be8944a 100644
--- a/transport/iowrapper.py
+++ b/transport/iowrapper.py
@@ -277,18 +277,17 @@ class IETL(BaseIO) :
             
             writer = _args['writer']
             _schema= _args['schema']
-            
-            for _item in _schema :
-                if _item['type'] == 'INTEGER' :
-                    _data.loc[:,_item['name']] = _data[_item['name']].copy().astype(np.int64)
-            writer.write(_data,schema=_schema)
             #
             # -- things to log
             _input = {'shape':_shape,'segment':_index}
             if hasattr(writer._agent,'_table'):
                 _input['table'] = writer._agent._table
-        except Exception as e:
+ 
+            
+            writer.write(_data,schema=_schema)
+       except Exception as e:
             _action = 'post-error'
+            _input['error'] = str(e)
             print ([e])
             pass