diff --git a/bin/transport.cmd b/bin/transport.cmd new file mode 100644 index 0000000..6125f7f --- /dev/null +++ b/bin/transport.cmd @@ -0,0 +1,2 @@ +cd /D "%~dp0" +python transport %1 %2 %3 %4 %5 %6 diff --git a/transport/other/files.py b/transport/other/files.py index f301370..6389012 100644 --- a/transport/other/files.py +++ b/transport/other/files.py @@ -33,12 +33,12 @@ class Reader (File): def read(self,**args): _path = self.path if 'path' not in args else args['path'] _delimiter = self.delimiter if 'delimiter' not in args else args['delimiter'] - + _df = pd.read_csv(_path,sep=self.delimiter) if not self._chunksize else self._stream(_path) - if 'query' in args : - _query = args['query'] - _df = _df.query(_query) - return _df + if 'query' in args : + _query = args['query'] + _df = _df.query(_query) + return _df def stream(self,**args): raise Exception ("streaming needs to be implemented") class Writer (File):