Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
log methods
  • Loading branch information
TomAugspurger committed Sep 27, 2024
commit a4dc888ebd5fcabbbe69a1781e95c5178c0785e3
17 changes: 10 additions & 7 deletions src/zarr/store/logging.py
Original file line number Diff line number Diff line change
Expand Up @@ -99,10 +99,12 @@ def _is_open(self) -> bool: # type: ignore[override]
return self._store._is_open

async def _open(self) -> None:
return await self._store._open()
with self.log():
return await self._store._open()

async def _ensure_open(self) -> None:
return await self._store._ensure_open()
with self.log():
return await self._store._ensure_open()

async def empty(self) -> bool:
with self.log():
Expand Down Expand Up @@ -173,8 +175,9 @@ async def list_dir(self, prefix: str) -> AsyncGenerator[str, None]:
yield key

def with_mode(self, mode: AccessModeLiteral) -> Self:
return type(self)(
self._store.with_mode(mode),
log_level=self.log_level,
log_handler=self.log_handler,
)
with self.log():
return type(self)(
self._store.with_mode(mode),
log_level=self.log_level,
log_handler=self.log_handler,
)