Updated pre-commit modules and fixed resulting mypy errors

.pre-commit-config.yaml

@@ -5,7 +5,7 @@
 # * Run "pre-commit install".
 repos:
  - repo: https://github.com/pre-commit/pre-commit-hooks
- rev: v4.1.0
+ rev: v4.2.0
  hooks:
  - id: check-toml
  - id: check-yaml
@@ -16,7 +16,7 @@ repos:
  - id: trailing-whitespace
 
  - repo: https://github.com/asottile/pyupgrade
- rev: v2.31.0
+ rev: v2.32.1
  hooks:
  - id: pyupgrade
  args: [ "--py36-plus", "--keep-mock" ]
@@ -32,12 +32,12 @@ repos:
  - id: isort
 
  - repo: https://github.com/csachs/pyproject-flake8
- rev: v0.0.1a2.post1
+ rev: v0.0.1a4
  hooks:
  - id: pyproject-flake8
 
  - repo: https://github.com/pre-commit/mirrors-mypy
- rev: v0.931
+ rev: v0.950
  hooks:
  - id: mypy
  additional_dependencies: [ "pytest", "trio-typing", "packaging" ]

src/anyio/_backends/_asyncio.py

@@ -183,7 +183,7 @@ def get_callable_name(func: Callable) -> str:
 
 def _task_started(task: asyncio.Task) -> bool:
  """Return ``True`` if the task has been started and has not finished."""
- coro = get_coro(task)
+ coro = cast(Coroutine[Any, Any, Any], get_coro(task))
  try:
  return getcoroutinestate(coro) in (CORO_RUNNING, CORO_SUSPENDED)
  except AttributeError:
@@ -1362,7 +1362,7 @@ async def accept(self) -> abc.SocketStream:
 
  client_sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
  transport, protocol = await self._loop.connect_accepted_socket(StreamProtocol, client_sock)
- return SocketStream(cast(asyncio.Transport, transport), cast(StreamProtocol, protocol))
+ return SocketStream(cast(asyncio.Transport, transport), protocol)
 
  async def aclose(self) -> None:
  if self._closed:
@@ -1552,7 +1552,7 @@ async def create_udp_socket(
  DatagramProtocol, local_addr=local_address, remote_addr=remote_address, family=family,
  reuse_port=reuse_port)
  transport = cast(asyncio.DatagramTransport, result[0])
- protocol = cast(DatagramProtocol, result[1])
+ protocol = result[1]
  if protocol.exception:
  transport.close()
  raise protocol.exception
@@ -1568,7 +1568,7 @@ async def getaddrinfo(host: Union[bytes, str], port: Union[str, int, None], *,
  proto: int = 0, flags: int = 0) -> GetAddrInfoReturnType:
  # https://github.com/python/typeshed/pull/4304
  result = await get_running_loop().getaddrinfo(
- host, port, family=family, type=type, proto=proto, flags=flags) # type: ignore[arg-type]
+ host, port, family=family, type=type, proto=proto, flags=flags)
  return cast(GetAddrInfoReturnType, result)
 
 

src/anyio/from_thread.py

@@ -394,8 +394,12 @@ async def run_portal() -> None:
 
  future: Future[BlockingPortal] = Future()
  with ThreadPoolExecutor(1) as executor:
- run_future = executor.submit(_eventloop.run, run_portal, backend=backend,
- backend_options=backend_options)
+ run_future = executor.submit(
+ _eventloop.run,
+ run_portal, # type: ignore[arg-type]
+ backend=backend,
+ backend_options=backend_options
+ )
  try:
  wait(cast(Iterable[Future], [run_future, future]), return_when=FIRST_COMPLETED)
  except BaseException:

tests/test_debugging.py

@@ -102,7 +102,9 @@ def generator_part() -> Generator[object, BaseException, None]:
  yield from event.wait()
 
  event = asyncio.Event()
- gen_task = asyncio_event_loop.create_task(generator_part())
+ gen_task: asyncio.Task[None] = asyncio_event_loop.create_task(
+ generator_part() # type: ignore[arg-type]
+ )
  asyncio_event_loop.run_until_complete(native_coro_part())
 
 
@@ -116,7 +118,7 @@ async def agen_func() -> AsyncGenerator[None, None]:
  agen = agen_func()
  coro = agen.asend(None)
  loop = asyncio.get_event_loop()
- task = loop.create_task(coro)
+ task: asyncio.Task[None] = loop.create_task(coro) # type: ignore[arg-type]
  await wait_all_tasks_blocked()
  await task
  await agen.aclose()

tests/test_taskgroups.py

@@ -546,7 +546,7 @@ async def host_agen_fn() -> AsyncGenerator[None, None]:
 
  host_agen = host_agen_fn()
  try:
- await asyncio.get_event_loop().create_task(host_agen.__anext__())
+ await asyncio.get_event_loop().create_task(host_agen.__anext__()) # type: ignore[arg-type]
  finally:
  await host_agen.aclose()