Skip to content

Commit 5cfc48e

Browse files
committed
chore: Update version to 0.10.7.4; fix incorrect attribute reference for filesystem mapper in job queue and pipeline manager
1 parent 717ffe6 commit 5cfc48e

File tree

4 files changed

+4
-4
lines changed

4 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.10.7.3"
7+
version = "0.10.7.4"
88
keywords = [
99
"hamilton",
1010
"workflow",

src/flowerpower/job_queue/base.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -387,7 +387,7 @@ def _add_modules_path(self):
387387
"""
388388
if self._fs.is_cache_fs:
389389
self._fs.sync_cache()
390-
project_path = self._fs_mapper.directory
390+
project_path = self._fs._mapper.directory
391391
modules_path = posixpath.join(project_path, self._pipelines_dir)
392392

393393
else:

src/flowerpower/pipeline/base.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ def _add_modules_path(self):
8181
"""
8282
if self._fs.is_cache_fs:
8383
self._fs.sync_cache()
84-
modules_path = posixpath.join(self._fs_mapper.directory, self._fs.cache_path, self._pipelines_dir)
84+
modules_path = posixpath.join(self._fs._mapper.directory, self._fs.cache_path, self._pipelines_dir)
8585
else:
8686
modules_path = posixpath.join(self._fs.path, self._pipelines_dir)
8787
if modules_path not in sys.path:

src/flowerpower/pipeline/manager.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -270,7 +270,7 @@ def _add_modules_path(self) -> None:
270270
"""
271271
if self._fs.is_cache_fs:
272272
self._fs.sync_cache()
273-
project_path = self._fs_mapper.directory
273+
project_path = self._fs._mapper.directory
274274
modules_path = posixpath.join(project_path, self._pipelines_dir)
275275

276276
else:

0 commit comments

Comments
 (0)