Bump version to 0.9.6.5; remove debug print statements and add write_file and write_files methods to AbstractFileSystem

Author: legout

pyproject.toml

@@ -4,7 +4,7 @@ description = "A simple workflow framework. Hamilton + APScheduler = FlowerPower
 authors = [{ name = "Volker L.", email = "[email protected]" }]
 readme = "README.md"
 requires-python = ">= 3.11"
-version = "0.9.6.4"
+version = "0.9.6.5"
 keywords = ["hamilton", "workflow", "pipeline", "scheduler", "apscheduler", "dask", "ray"]
 dependencies = [
   "sf-hamilton[visualization]>=1.69.0",

src/flowerpower/filesystem/ext.py

@@ -499,14 +499,12 @@ def _read_parquet(
     """
     if not include_file_path and concat:
         path = path.replace("**", "").replace("*.parquet", "")
-        print(path)
         return pq.read_table(path, filesystem=self, **kwargs)
     else:
         if isinstance(path, str):
             path = path_to_glob(path, format="parquet")
             path = self.glob(path)
 
-        # print(path)
         if isinstance(path, list):
             if use_threads:
                 table = run_parallel(
@@ -1368,5 +1366,7 @@ def write_pydala_dataset(
 AbstractFileSystem.write_parquet = write_parquet
 AbstractFileSystem.write_json = write_json
 AbstractFileSystem.write_csv = write_csv
+AbstractFileSystem.write_file = write_file
+AbstractFileSystem.write_files = write_files
 AbstractFileSystem.write_pyarrow_dataset = write_pyarrow_dataset
 AbstractFileSystem.write_pydala_dataset = write_pydala_dataset