diff --git a/transport/disk.py b/transport/disk.py index 1d966c7..d8ee757 100644 --- a/transport/disk.py +++ b/transport/disk.py @@ -95,7 +95,7 @@ class DiskWriter(Writer): _delim = self._delimiter if 'delimiter' not in _args else _args['delimiter'] _path = self._path if 'path' not in _args else _args['path'] _mode = self._mode if 'mode' not in _args else _args['mode'] - info.to_csv(_path,index=False,sep=_delim, mode=_mode) + info.to_csv(_path,index=False,sep=_delim) pass except Exception as e: # diff --git a/transport/etl.py b/transport/etl.py index b2e0e6a..198bdf0 100644 --- a/transport/etl.py +++ b/transport/etl.py @@ -99,7 +99,7 @@ class Transporter(Process): # _target['write']['lock'] = True pass _writer = transport.factory.instance(**_target) - _writer.write(_data.copy(),**_args) + _writer.write(_data,**_args) if hasattr(_writer,'close') : _writer.close()