From a4b4a453bb217997972cf3a6dfee9d310bea2ddb Mon Sep 17 00:00:00 2001
From: Steve Nyemba <nyemba@gmail.com>
Date: Tue, 28 Jan 2025 19:37:49 -0600
Subject: [PATCH] bug fix: etl & logger

---
 transport/iowrapper.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/transport/iowrapper.py b/transport/iowrapper.py
index 88224f9..2f80edd 100644
--- a/transport/iowrapper.py
+++ b/transport/iowrapper.py
@@ -283,7 +283,10 @@ class IETL(BaseIO) :
             if hasattr(writer._agent,'_table'):
                 _input['table'] = writer._agent._table
  
-            
+            for _item in _schema :
+                if _item['type'] in ['INTEGER','BIGINT','INT'] :
+                    _column  = _item['name']
+                    _data[_column] = _data[_column].copy().fillna(0).astype(np.int64)
             writer.write(_data,schema=_schema)
         except Exception as e:
             _action = 'post-error'