From a4597d4a8c5e5b5b036f7672ccd5a5ee865d8044 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Thu, 9 Oct 2025 19:34:17 -0500 Subject: [PATCH 1/2] adding queries to files --- transport/other/files.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/transport/other/files.py b/transport/other/files.py index 62ee3c4..57d3f25 100644 --- a/transport/other/files.py +++ b/transport/other/files.py @@ -30,7 +30,11 @@ 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'] - return pd.read_csv(_path,delimiter=self.delimiter) + _df = pd.read_csv(_path,delimiter=self.delimiter) + 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): From de4ee2fcfaccb6a87d715fbfbfe670bf0f433268 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Thu, 9 Oct 2025 21:13:22 -0500 Subject: [PATCH 2/2] bug fixes ... windows runner, files --- bin/transport.cmd | 2 ++ pyproject.toml | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) create mode 100644 bin/transport.cmd 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/pyproject.toml b/pyproject.toml index 742915d..b04071d 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -39,7 +39,7 @@ Homepage = "https://healthcareio.the-phi.com/git/code/transport.git" [tool.setuptools] include-package-data = true zip-safe = false -script-files = ["bin/transport"] +script-files = ["bin/transport","bin/transport.cmd"] [tool.setuptools.packages.find] include = ["info","info.*", "transport", "transport.*"]