Fixed mypy errors

Author: agronholm

src/redis_anyio/_connection.py

@@ -106,7 +106,9 @@ async def aclose(self, *, force: bool = True) -> None:
         else:
             await self._send_stream.aclose()
 
-    async def run(self, stream: AnyByteStream, *, task_status: TaskStatus) -> None:
+    async def run(
+        self, stream: AnyByteStream, *, task_status: TaskStatus[None]
+    ) -> None:
         send, self._response_stream = create_memory_object_stream(100)
         async with stream, send:
             self._send_stream = stream

src/redis_anyio/_lock.py

@@ -82,7 +82,7 @@ async def _run_script(
             await self.client.script_load(source)
             return await self.client.evalsha(script_sha1, [self.name], list(args))
 
-    async def _run(self, *, task_status: TaskStatus) -> None:
+    async def _run(self, *, task_status: TaskStatus[None]) -> None:
         while not await self._run_script(
             ACQUIRE_SCRIPT, ACQUIRE_SCRIPT_SHA, self._token, self.lifetime
         ):

tests/test_client.py

@@ -587,7 +587,7 @@ class TestLock:
     async def test_locking(self, redis_port: int, separate_locks: bool) -> None:
         events: list[str] = []
 
-        async def acquire_lock(*, task_status: TaskStatus) -> None:
+        async def acquire_lock(*, task_status: TaskStatus[None]) -> None:
             async with lock1:
                 task_status.started()
                 events.append("subtask acquired the lock")
@@ -633,7 +633,7 @@ async def test_task_holding_lock_cancelled(
         one from getting the lock.
         """
 
-        async def acquire_lock(*, task_status: TaskStatus) -> None:
+        async def acquire_lock(*, task_status: TaskStatus[None]) -> None:
             async with lock:
                 task_status.started()
                 await sleep(5)