approach the coverage problems by reducing the denominator

d-v-b · d-v-b · commit e5ffc334e9c7 · 2025-08-01T18:36:54.000+02:00
diff --git a/src/zarr/abc/codec.py b/src/zarr/abc/codec.py
@@ -138,7 +138,7 @@ def validate(
         """
 
     async def _decode_single(self, chunk_data: CodecOutput, chunk_spec: ArraySpec) -> CodecInput:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     async def decode(
         self,
@@ -161,7 +161,7 @@ async def decode(
     async def _encode_single(
         self, chunk_data: CodecInput, chunk_spec: ArraySpec
     ) -> CodecOutput | None:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     async def encode(
         self,
@@ -203,7 +203,7 @@ class ArrayBytesCodecPartialDecodeMixin:
     async def _decode_partial_single(
         self, byte_getter: ByteGetter, selection: SelectorTuple, chunk_spec: ArraySpec
     ) -> NDBuffer | None:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     async def decode_partial(
         self,
@@ -242,7 +242,7 @@ async def _encode_partial_single(
         selection: SelectorTuple,
         chunk_spec: ArraySpec,
     ) -> None:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     async def encode_partial(
         self,
@@ -321,7 +321,7 @@ def from_array_metadata_and_store(cls, array_metadata: ArrayMetadata, store: Sto
         -------
         Self
         """
-        raise NotImplementedError(
+        raise NotImplementedError(  # pragma: no cover
             f"'{type(cls).__name__}' does not implement CodecPipeline.from_array_metadata_and_store."
         )
 
diff --git a/src/zarr/abc/store.py b/src/zarr/abc/store.py
@@ -100,7 +100,7 @@ def with_read_only(self, read_only: bool = False) -> Store:
         -------
             A new store of the same type with the new read only attribute.
         """
-        raise NotImplementedError(
+        raise NotImplementedError(  # pragma: no cover
             f"with_read_only is not implemented for the {type(self)} store type."
         )
 
@@ -150,7 +150,7 @@ async def is_empty(self, prefix: str) -> bool:
             True if the store is empty, False otherwise.
         """
         if not self.supports_listing:
-            raise NotImplementedError
+            raise NotImplementedError  # pragma: no cover
         if prefix != "" and not prefix.endswith("/"):
             prefix += "/"
         async for _ in self.list_prefix(prefix):
@@ -164,9 +164,9 @@ async def clear(self) -> None:
         Remove all keys and values from the store.
         """
         if not self.supports_deletes:
-            raise NotImplementedError
+            raise NotImplementedError  # pragma: no cover
         if not self.supports_listing:
-            raise NotImplementedError
+            raise NotImplementedError  # pragma: no cover
         self._check_writable()
         await self.delete_dir("")
 
@@ -393,9 +393,9 @@ async def delete_dir(self, prefix: str) -> None:
         Remove all keys and prefixes in the store that begin with a given prefix.
         """
         if not self.supports_deletes:
-            raise NotImplementedError
+            raise NotImplementedError  # pragma: no cover
         if not self.supports_listing:
-            raise NotImplementedError
+            raise NotImplementedError  # pragma: no cover
         self._check_writable()
         if prefix != "" and not prefix.endswith("/"):
             prefix += "/"
diff --git a/src/zarr/api/asynchronous.py b/src/zarr/api/asynchronous.py
@@ -244,15 +244,15 @@ async def consolidate_metadata(
 
 
 async def copy(*args: Any, **kwargs: Any) -> tuple[int, int, int]:
-    raise NotImplementedError
+    raise NotImplementedError  # pragma: no cover
 
 
 async def copy_all(*args: Any, **kwargs: Any) -> tuple[int, int, int]:
-    raise NotImplementedError
+    raise NotImplementedError  # pragma: no cover
 
 
 async def copy_store(*args: Any, **kwargs: Any) -> tuple[int, int, int]:
-    raise NotImplementedError
+    raise NotImplementedError  # pragma: no cover
 
 
 async def load(
diff --git a/src/zarr/codecs/_v2.py b/src/zarr/codecs/_v2.py
@@ -152,4 +152,4 @@ async def _encode_single(
         return chunk_spec.prototype.buffer.from_bytes(cdata)
 
     def compute_encoded_size(self, _input_byte_length: int, _chunk_spec: ArraySpec) -> int:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
diff --git a/src/zarr/codecs/blosc.py b/src/zarr/codecs/blosc.py
@@ -198,7 +198,7 @@ async def _encode_single(
         )
 
     def compute_encoded_size(self, _input_byte_length: int, _chunk_spec: ArraySpec) -> int:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
 
 register_codec("blosc", BloscCodec)
diff --git a/src/zarr/codecs/gzip.py b/src/zarr/codecs/gzip.py
@@ -72,7 +72,7 @@ def compute_encoded_size(
         _input_byte_length: int,
         _chunk_spec: ArraySpec,
     ) -> int:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
 
 register_codec("gzip", GzipCodec)
diff --git a/src/zarr/codecs/sharding.py b/src/zarr/codecs/sharding.py
@@ -264,7 +264,7 @@ def __setitem__(self, chunk_coords: ChunkCoords, value: Buffer) -> None:
         self.index.set_chunk_slice(chunk_coords, slice(chunk_start, chunk_start + chunk_length))
 
     def __delitem__(self, chunk_coords: ChunkCoords) -> None:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     async def finalize(
         self,
diff --git a/src/zarr/codecs/vlen_utf8.py b/src/zarr/codecs/vlen_utf8.py
@@ -67,7 +67,9 @@ async def _encode_single(
 
     def compute_encoded_size(self, input_byte_length: int, _chunk_spec: ArraySpec) -> int:
         # what is input_byte_length for an object dtype?
-        raise NotImplementedError("compute_encoded_size is not implemented for VLen codecs")
+        raise NotImplementedError(
+            "compute_encoded_size is not implemented for VLen codecs"
+        )  # pragma: no cover
 
 
 @dataclass(frozen=True)
@@ -111,7 +113,9 @@ async def _encode_single(
 
     def compute_encoded_size(self, input_byte_length: int, _chunk_spec: ArraySpec) -> int:
         # what is input_byte_length for an object dtype?
-        raise NotImplementedError("compute_encoded_size is not implemented for VLen codecs")
+        raise NotImplementedError(
+            "compute_encoded_size is not implemented for VLen codecs"
+        )  # pragma: no cover
 
 
 register_codec("vlen-utf8", VLenUTF8Codec)
diff --git a/src/zarr/codecs/zstd.py b/src/zarr/codecs/zstd.py
@@ -91,7 +91,7 @@ async def _encode_single(
         )
 
     def compute_encoded_size(self, _input_byte_length: int, _chunk_spec: ArraySpec) -> int:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
 
 register_codec("zstd", ZstdCodec)
diff --git a/src/zarr/core/buffer/core.py b/src/zarr/core/buffer/core.py
@@ -225,7 +225,9 @@ def from_bytes(cls, bytes_like: BytesLike) -> Self:
             New buffer representing `bytes_like`
         """
         if cls is Buffer:
-            raise NotImplementedError("Cannot call abstract method on the abstract class 'Buffer'")
+            raise NotImplementedError(
+                "Cannot call abstract method on the abstract class 'Buffer'"
+            )  # pragma: no cover
         return cls(
             cast("ArrayLike", None)
         )  # This line will never be reached, but it satisfies the type checker
@@ -367,7 +369,7 @@ def create(
         other then the default Numpy array.
         """
         if cls is NDBuffer:
-            raise NotImplementedError(
+            raise NotImplementedError(  # pragma: no cover
                 "Cannot call abstract method on the abstract class 'NDBuffer'"
             )
         return cls(
@@ -439,7 +441,7 @@ def from_numpy_array(cls, array_like: npt.ArrayLike) -> Self:
             New buffer representing `array_like`
         """
         if cls is NDBuffer:
-            raise NotImplementedError(
+            raise NotImplementedError(  # pragma: no cover
                 "Cannot call abstract method on the abstract class 'NDBuffer'"
             )
         return cls(
diff --git a/src/zarr/core/dtype/common.py b/src/zarr/core/dtype/common.py
@@ -191,7 +191,7 @@ class HasItemSize:
 
     @property
     def item_size(self) -> int:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
 
 @dataclass(frozen=True, kw_only=True)
diff --git a/src/zarr/core/group.py b/src/zarr/core/group.py
@@ -1606,7 +1606,7 @@ async def tree(self, expand: bool | None = None, level: int | None = None) -> An
         from zarr.core._tree import group_tree_async
 
         if expand is not None:
-            raise NotImplementedError("'expand' is not yet implemented.")
+            raise NotImplementedError("'expand' is not yet implemented.")  # pragma: no cover
         return await group_tree_async(self, max_depth=level)
 
     async def empty(
@@ -1795,7 +1795,7 @@ async def move(self, source: str, dest: str) -> None:
         -----
         Not implemented
         """
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
 
 @dataclass(frozen=True)
diff --git a/src/zarr/core/indexing.py b/src/zarr/core/indexing.py
@@ -171,7 +171,7 @@ def _iter_grid(
 
     else:
         msg = f"Indexing order {order} is not supported at this time."  # type: ignore[unreachable]
-        raise NotImplementedError(msg)
+        raise NotImplementedError(msg)  # pragma: no cover
 
 
 def is_integer(x: Any) -> TypeGuard[int]:
diff --git a/src/zarr/core/metadata/v3.py b/src/zarr/core/metadata/v3.py
@@ -239,7 +239,7 @@ def chunks(self) -> ChunkCoords:
             f"The `chunks` attribute is only defined for arrays using `RegularChunkGrid`."
             f"This array has a {self.chunk_grid} instead."
         )
-        raise NotImplementedError(msg)
+        raise NotImplementedError(msg)  # pragma: no cover
 
     @property
     def shards(self) -> ChunkCoords | None:
@@ -255,7 +255,7 @@ def shards(self) -> ChunkCoords | None:
             f"The `shards` attribute is only defined for arrays using `RegularChunkGrid`."
             f"This array has a {self.chunk_grid} instead."
         )
-        raise NotImplementedError(msg)
+        raise NotImplementedError(msg)  # pragma: no cover
 
     @property
     def inner_codecs(self) -> tuple[Codec, ...]:
diff --git a/src/zarr/storage/_fsspec.py b/src/zarr/storage/_fsspec.py
@@ -343,7 +343,7 @@ async def set(
         path = _dereference_path(self.path, key)
         # write data
         if byte_range:
-            raise NotImplementedError
+            raise NotImplementedError  # pragma: no cover
         await self.fs._pipe_file(path, value.to_bytes())
 
     async def delete(self, key: str) -> None:
@@ -360,7 +360,7 @@ async def delete(self, key: str) -> None:
     async def delete_dir(self, prefix: str) -> None:
         # docstring inherited
         if not self.supports_deletes:
-            raise NotImplementedError(
+            raise NotImplementedError(  # pragma: no cover
                 "This method is only available for stores that support deletes."
             )
         self._check_writable()
@@ -420,7 +420,7 @@ async def set_partial_values(
         self, key_start_values: Iterable[tuple[str, int, BytesLike]]
     ) -> None:
         # docstring inherited
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     async def list(self) -> AsyncIterator[str]:
         # docstring inherited
diff --git a/src/zarr/storage/_logging.py b/src/zarr/storage/_logging.py
@@ -137,7 +137,9 @@ def _is_open(self) -> bool:
 
     @_is_open.setter
     def _is_open(self, value: bool) -> None:
-        raise NotImplementedError("LoggingStore must be opened via the `_open` method")
+        raise NotImplementedError(
+            "LoggingStore must be opened via the `_open` method"
+        )  # pragma: no cover
 
     async def _open(self) -> None:
         with self.log():
diff --git a/src/zarr/storage/_memory.py b/src/zarr/storage/_memory.py
@@ -147,7 +147,7 @@ async def set_partial_values(
         self, key_start_values: Iterable[tuple[str, int, bytes | bytearray | memoryview[int]]]
     ) -> None:
         # docstring inherited
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     async def list(self) -> AsyncIterator[str]:
         # docstring inherited
diff --git a/src/zarr/storage/_obstore.py b/src/zarr/storage/_obstore.py
@@ -205,7 +205,7 @@ async def set_partial_values(
         self, key_start_values: Iterable[tuple[str, int, BytesLike]]
     ) -> None:
         # docstring inherited
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     @property
     def supports_listing(self) -> bool:
diff --git a/src/zarr/storage/_wrapper.py b/src/zarr/storage/_wrapper.py
@@ -63,7 +63,9 @@ def _is_open(self) -> bool:
 
     @_is_open.setter
     def _is_open(self, value: bool) -> None:
-        raise NotImplementedError("WrapperStore must be opened via the `_open` method")
+        raise NotImplementedError(
+            "WrapperStore must be opened via the `_open` method"
+        )  # pragma: no cover
 
     async def clear(self) -> None:
         return await self._store.clear()
diff --git a/src/zarr/storage/_zip.py b/src/zarr/storage/_zip.py
@@ -225,7 +225,7 @@ async def set(self, key: str, value: Buffer) -> None:
     async def set_partial_values(
         self, key_start_values: Iterable[tuple[str, int, bytes | bytearray | memoryview[int]]]
     ) -> None:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     async def set_if_not_exists(self, key: str, value: Buffer) -> None:
         self._check_writable()
@@ -240,15 +240,15 @@ async def delete_dir(self, prefix: str) -> None:
         if prefix != "" and not prefix.endswith("/"):
             prefix += "/"
         async for _ in self.list_prefix(prefix):
-            raise NotImplementedError
+            raise NotImplementedError  # pragma: no cover
 
     async def delete(self, key: str) -> None:
         # docstring inherited
         # we choose to only raise NotImplementedError here if the key exists
         # this allows the array/group APIs to avoid the overhead of existence checks
         self._check_writable()
         if await self.exists(key):
-            raise NotImplementedError
+            raise NotImplementedError  # pragma: no cover
 
     async def exists(self, key: str) -> bool:
         # docstring inherited
diff --git a/src/zarr/testing/stateful.py b/src/zarr/testing/stateful.py
@@ -462,13 +462,13 @@ def exists(self, key: str) -> bool:
         return self._sync(self.store.exists(key))
 
     def list_dir(self, prefix: str) -> None:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     def list_prefix(self, prefix: str) -> None:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     def set_partial_values(self, key_start_values: Any) -> None:
-        raise NotImplementedError
+        raise NotImplementedError  # pragma: no cover
 
     @property
     def supports_listing(self) -> bool:

Original file line number	Diff line number	Diff line change
`@@ -198,7 +198,7 @@ async def _encode_single(`
`198`	`198`	`)`
`199`	`199`
`200`	`200`	`def compute_encoded_size(self, _input_byte_length: int, _chunk_spec: ArraySpec) -> int:`
`201`		`- raise NotImplementedError`
	`201`	`+ raise NotImplementedError # pragma: no cover`
`202`	`202`
`203`	`203`
`204`	`204`	`register_codec("blosc", BloscCodec)`
Original file line number	Diff line number	Diff line change
`@@ -91,7 +91,7 @@ async def _encode_single(`
`91`	`91`	`)`
`92`	`92`
`93`	`93`	`def compute_encoded_size(self, _input_byte_length: int, _chunk_spec: ArraySpec) -> int:`
`94`		`- raise NotImplementedError`
	`94`	`+ raise NotImplementedError # pragma: no cover`
`95`	`95`
`96`	`96`
`97`	`97`	`register_codec("zstd", ZstdCodec)`