Skip to content

Commit 6b82a60

Browse files
committed
Bump version to 0.9.6.7; update data handling in BaseFileWriter and BaseDatasetWriter to avoid using None
1 parent 95fc710 commit 6b82a60

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ description = "A simple workflow framework. Hamilton + APScheduler = FlowerPower
44
authors = [{ name = "Volker L.", email = "[email protected]" }]
55
readme = "README.md"
66
requires-python = ">= 3.11"
7-
version = "0.9.6.6"
7+
version = "0.9.6.7"
88
keywords = ["hamilton", "workflow", "pipeline", "scheduler", "apscheduler", "dask", "ray"]
99
dependencies = [
1010
"sf-hamilton[visualization]>=1.69.0",

src/flowerpower/io/base.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -772,7 +772,7 @@ def write(
772772
**kwargs,
773773
):
774774
self.fs.write_files(
775-
data=data or self.data,
775+
data=data if data is not None else self.data,
776776
basename=basename or self.basename,
777777
concat=concat or self.concat,
778778
mode=mode or self.mode,
@@ -868,7 +868,7 @@ def write(
868868

869869
if not self.is_pydala_dataset:
870870
self.fs.write_pyarrow_dataset(
871-
data=data or self.data,
871+
data=data if data is not None else self.data,
872872
path=self._path,
873873
basename=basename or self.basename,
874874
schema=schema or self.schema_,
@@ -884,7 +884,7 @@ def write(
884884
)
885885
else:
886886
self.fs.write_pydala_dataset(
887-
data=data or self.data,
887+
data=data if data is not None else self.data,
888888
path=self._path,
889889
mode=mode,
890890
basename=basename or self.basename,

0 commit comments

Comments
 (0)