lint

Author: d-v-b

src/zarr/testing/store_concurrency.py

@@ -84,8 +84,8 @@ async def test_concurrency_limit_enforced(self, store_kwargs: dict[str, Any]) ->
         if not issubclass(self.store_cls, ConcurrencyLimiter):
             pytest.skip("Store does not support concurrency limits")
 
-        limit = 3
-        store = self.store_cls(**{**store_kwargs, "concurrency_limit": limit})  # type: ignore[unreachable]
+        limit = 3  # type: ignore[unreachable]
+        store = self.store_cls(**{**store_kwargs, "concurrency_limit": limit})
         await store._ensure_open()
 
         sem = store._semaphore
@@ -94,7 +94,7 @@ async def test_concurrency_limit_enforced(self, store_kwargs: dict[str, Any]) ->
         # Exhaust all slots
         for _ in range(limit):
             await sem.acquire()
-        assert sem._value == 0  # type: ignore[attr-defined]
+        assert sem._value == 0
 
         # A store operation should block because no slots are available
         buf = self.buffer_cls.from_bytes(b"x")

tests/test_store/test_local.py

@@ -204,4 +204,3 @@ def test_atomic_write_exclusive_preexisting(tmp_path: pathlib.Path) -> None:
             f.write(b"abc")
     assert path.read_bytes() == b"xyz"
     assert list(path.parent.iterdir()) == [path]  # no temp files
-