From a7fe357b2c4687cc736bcaaf56a7de71de6fa162 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Sat, 30 Sep 2023 09:24:58 -0500 Subject: [PATCH] bug fixes, write file and other misc with ETL --- transport/disk.py | 2 +- transport/etl.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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()