Compare commits

..

No commits in common. 'de4ee2fcfaccb6a87d715fbfbfe670bf0f433268' and '4c2efc28924b543306768dda240cbde6b7eae034' have entirely different histories.

@ -1,2 +0,0 @@
cd /D "%~dp0"
python transport %1 %2 %3 %4 %5 %6

@ -39,7 +39,7 @@ Homepage = "https://healthcareio.the-phi.com/git/code/transport.git"
[tool.setuptools] [tool.setuptools]
include-package-data = true include-package-data = true
zip-safe = false zip-safe = false
script-files = ["bin/transport","bin/transport.cmd"] script-files = ["bin/transport"]
[tool.setuptools.packages.find] [tool.setuptools.packages.find]
include = ["info","info.*", "transport", "transport.*"] include = ["info","info.*", "transport", "transport.*"]

@ -30,11 +30,7 @@ class Reader (File):
def read(self,**args): def read(self,**args):
_path = self.path if 'path' not in args else args['path'] _path = self.path if 'path' not in args else args['path']
_delimiter = self.delimiter if 'delimiter' not in args else args['delimiter'] _delimiter = self.delimiter if 'delimiter' not in args else args['delimiter']
_df = pd.read_csv(_path,delimiter=self.delimiter) return pd.read_csv(_path,delimiter=self.delimiter)
if 'query' in args :
_query = args['query']
_df = _df.query(_query)
return _df
def stream(self,**args): def stream(self,**args):
raise Exception ("streaming needs to be implemented") raise Exception ("streaming needs to be implemented")
class Writer (File): class Writer (File):

Loading…
Cancel
Save