fix(service): Better paths

openclimatefix · Nov 11, 2024 · 7bc387f · 7bc387f
1 parent a30564c
commit 7bc387f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/nwp_consumer/internal/services/archiver_service.py b/src/nwp_consumer/internal/services/archiver_service.py
@@ -120,7 +120,7 @@ def archive(self, year: int, month: int) -> ResultE[pathlib.Path]:
                 monitor.join()
                 notify_result = self.nr().notify(
                     message=entities.StoreCreatedNotification(
-                        filename=store.path.name,
+                        filename=pathlib.Path(store.path).name,
                         size_mb=store.size_kb // 1024,
                         performance=entities.PerformanceMetadata(
                             duration_seconds=monitor.get_runtime(),

diff --git a/src/nwp_consumer/internal/services/consumer_service.py b/src/nwp_consumer/internal/services/consumer_service.py
@@ -124,7 +124,7 @@ def consume(self, it: dt.datetime | None = None) -> ResultE[pathlib.Path]:
                 monitor.join()
                 notify_result = self.nr().notify(
                     message=entities.StoreCreatedNotification(
-                        filename=store.path.name,
+                        filename=pathlib.Path(store.path).name,
                         size_mb=store.size_kb // 1024,
                         performance=entities.PerformanceMetadata(
                             duration_seconds=monitor.get_runtime(),