From 977aa910457aab46ead405b152887d49ee0cd92d Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Thu, 9 Oct 2025 21:14:52 -0500 Subject: [PATCH] bug fix & added windows runner --- pyproject.toml | 2 +- transport/other/files.py | 8 ++++++-- 2 files changed, 7 insertions(+), 3 deletions(-) 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.*"] diff --git a/transport/other/files.py b/transport/other/files.py index 6679285..f301370 100644 --- a/transport/other/files.py +++ b/transport/other/files.py @@ -34,7 +34,11 @@ class Reader (File): _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,sep=self.delimiter) if not self._chunksize else self._stream(_path) + _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 def stream(self,**args): raise Exception ("streaming needs to be implemented") class Writer (File): @@ -70,4 +74,4 @@ class Writer (File): pass finally: # DiskWriter.THREAD_LOCK.release() - pass \ No newline at end of file + pass -- 2.34.1