mypy: use latest mypy

Author: hauntsaninja

boostedblob/boost.py

@@ -544,7 +544,9 @@ async def eagerly_buffer(self) -> None:
             # We can't use async for because we need to preserve exceptions
             it = self.iterable.__aiter__()
             while True:
-                task = asyncio.create_task(it.__anext__())
+                # I guess in theory, __anext__ isn't guaranteed to be a coroutine
+                # https://github.com/hauntsaninja/boostedblob/pull/12
+                task: asyncio.Task[T] = asyncio.create_task(it.__anext__())  # type: ignore [arg-type]
                 try:
                     await task
                 except StopAsyncIteration:

boostedblob/cli.py

@@ -6,15 +6,15 @@
 import subprocess
 import sys
 import tempfile
-from typing import Any, AsyncIterator, Awaitable, Callable, Dict, List, Optional, TypeVar, cast
+from typing import Any, AsyncIterator, Callable, Coroutine, Dict, List, Optional, TypeVar, cast
 
 import boostedblob as bbb
 
 F = TypeVar("F", bound=Callable[..., Any])
 T = TypeVar("T")
 
 
-def syncify(fn: Callable[..., Awaitable[T]]) -> Callable[..., T]:
+def syncify(fn: Callable[..., Coroutine[T, None, None]]) -> Callable[..., T]:
     @functools.wraps(fn)
     def wrapper(*args: Any, **kwargs: Any) -> Any:
         try:

poetry.lock

@@ -62,7 +62,7 @@ filelock = "*"
 ipdb = "*"
 black = "^22.6"
 isort = "^5.7.0"
-mypy = "^0.931"
+mypy = "^0.971"
 flake8 = "^3.8.3"
 types-xmltodict = "^0.12.0"
 

pyproject.toml

@@ -55,7 +55,7 @@ async def test_map_ordered_single():
         assert e.semaphore._value == 0
         assert set(futures) == set()
 
-        next_task = asyncio.create_task(it.__anext__())
+        next_task = asyncio.create_task(it.__anext__())  # type: ignore[arg-type]
         await pause()
         assert set(futures) == {0}
 
@@ -70,7 +70,7 @@ async def test_map_ordered_single():
         assert next_task.done()
         assert (await next_task) == 0
 
-        next_task = asyncio.create_task(it.__anext__())
+        next_task = asyncio.create_task(it.__anext__())  # type: ignore[arg-type]
         await pause()
         assert not next_task.done()
         futures[1].set_result(None)