bug fix: etl & logger

2 months ago · 93537095a4
parent 329a575f89
commit 93537095a4
1 changed files with 5 additions and 6 deletions
--- 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