Bump mypy from 0.982 to 1.4.1 (#7427)

Bumps [mypy](https://github.com/python/mypy) from 0.982 to 1.4.1. <details> <summary>Commits</summary> <ul> <li><a href="https://github.com/python/mypy/commit/3534bacc4c0d3c4b1983a533e2a36cce43f2ec9d"><code>3534bac</code></a> Remove +dev from version</li> <li><a href="https://github.com/python/mypy/commit/f36ea01e9de2ffac42a2615307f3692fd8e84c4a"><code>f36ea01</code></a> Fix async iterator body stripping (<a href="https://redirect.github.com/python/mypy/issues/15491">#15491</a>)</li> <li><a href="https://github.com/python/mypy/commit/ba7887be34391ae777cb32ca85719f3b3fa01c06"><code>ba7887b</code></a> Revert "Fix spurious errors on builtins.open (<a href="https://redirect.github.com/python/mypy/issues/15161">#15161</a>)" (<a href="https://redirect.github.com/python/mypy/issues/15508">#15508</a>)</li> <li><a href="https://github.com/python/mypy/commit/16fe5da0bd9be4d0669f00a47d260894c988cf87"><code>16fe5da</code></a> Fix readthedocs build (<a href="https://redirect.github.com/python/mypy/issues/15437">#15437</a>)</li> <li><a href="https://github.com/python/mypy/commit/9b327d12bc3b57cc30ed76dcd3e07a3674da17a2"><code>9b327d1</code></a> Use consistent anchors for error codes (<a href="https://redirect.github.com/python/mypy/issues/15435">#15435</a>)</li> <li><a href="https://github.com/python/mypy/commit/32abe0210092e6e074d9c2cc1862a3cf7c2421c5"><code>32abe02</code></a> docs: ref redirector (<a href="https://redirect.github.com/python/mypy/issues/15432">#15432</a>)</li> <li><a href="https://github.com/python/mypy/commit/e5a5b33e12e850d8cf11e156267adf8ee85e6221"><code>e5a5b33</code></a> Unbreak CI (<a href="https://redirect.github.com/python/mypy/issues/15505">#15505</a>)</li> <li><a href="https://github.com/python/mypy/commit/81d01aa0bdec8f9c2ed85d39b6077572abcda72a"><code>81d01aa</code></a> Fix PEP 561 editable install test case (<a href="https://redirect.github.com/python/mypy/issues/15493">#15493</a>)</li> <li><a href="https://github.com/python/mypy/commit/eba351e4016a57fad611cc14cef456a741a4713b"><code>eba351e</code></a> Add pip as test requirement for PEP 660 editable installs (<a href="https://redirect.github.com/python/mypy/issues/15482">#15482</a>)</li> <li><a href="https://github.com/python/mypy/commit/9faffe87c0f15980afc041183148829208f4fc8f"><code>9faffe8</code></a> Bump typing_extensions dependency (<a href="https://redirect.github.com/python/mypy/issues/15488">#15488</a>)</li> <li>Additional commits viewable in <a href="https://github.com/python/mypy/compare/v0.982...v1.4.1">compare view</a></li> </ul> </details> <br /> [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=mypy&package-manager=pip&previous-version=0.982&new-version=1.4.1)](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting `@dependabot rebase`. [//]: # (dependabot-automerge-start) [//]: # (dependabot-automerge-end) --- <details> <summary>Dependabot commands and options</summary> <br /> You can trigger Dependabot actions by commenting on this PR: - `@dependabot rebase` will rebase this PR - `@dependabot recreate` will recreate this PR, overwriting any edits that have been made to it - `@dependabot merge` will merge this PR after your CI passes on it - `@dependabot squash and merge` will squash and merge this PR after your CI passes on it - `@dependabot cancel merge` will cancel a previously requested merge and block automerging - `@dependabot reopen` will reopen this PR if it is closed - `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually - `@dependabot ignore this major version` will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself) - `@dependabot ignore this minor version` will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself) - `@dependabot ignore this dependency` will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself) </details> --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: dependabot[bot] <dependabot[bot]@users.noreply.github.com> Co-authored-by: Sam Bull <git@sambull.org> Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
aio-libs · Jul 27, 2023 · 63f83a0 · 63f83a0
1 parent 9481839
commit 63f83a0
Show file tree

Hide file tree

Showing 25 changed files with 67 additions and 61 deletions.
diff --git a/.mypy.ini b/.mypy.ini
@@ -4,21 +4,24 @@ check_untyped_defs = True
 follow_imports_for_stubs = True
 #disallow_any_decorated = True
 disallow_any_generics = True
+disallow_any_unimported = True
 disallow_incomplete_defs = True
 disallow_subclassing_any = True
 disallow_untyped_calls = True
 disallow_untyped_decorators = True
 disallow_untyped_defs = True
+enable_error_code = ignore-without-code, possibly-undefined, redundant-expr, redundant-self, truthy-bool, truthy-iterable, unused-awaitable
 implicit_reexport = False
 no_implicit_optional = True
+pretty = True
+show_column_numbers = True
 show_error_codes = True
 strict_equality = True
 warn_incomplete_stub = True
 warn_redundant_casts = True
+warn_return_any = True
 #warn_unreachable = True
 warn_unused_ignores = True
-disallow_any_unimported = True
-warn_return_any = True
 
 [mypy-aiodns]
 ignore_missing_imports = True

diff --git a/aiohttp/client.py b/aiohttp/client.py
@@ -16,6 +16,7 @@
     Any,
     Awaitable,
     Callable,
+    Collection,
     Coroutine,
     FrozenSet,
     Generator,
@@ -450,11 +451,7 @@ async def _request(
                         auth = self._default_auth
                     # It would be confusing if we support explicit
                     # Authorization header with auth argument
-                    if (
-                        headers is not None
-                        and auth is not None
-                        and hdrs.AUTHORIZATION in headers
-                    ):
+                    if auth is not None and hdrs.AUTHORIZATION in headers:
                         raise ValueError(
                             "Cannot combine AUTHORIZATION header "
                             "with AUTH argument or credentials "
@@ -666,7 +663,7 @@ def ws_connect(
         url: StrOrURL,
         *,
         method: str = hdrs.METH_GET,
-        protocols: Iterable[str] = (),
+        protocols: Collection[str] = (),
         timeout: Union[ClientWSTimeout, float, _SENTINEL, None] = sentinel,
         receive_timeout: Optional[float] = None,
         autoclose: bool = True,
@@ -712,7 +709,7 @@ async def _ws_connect(
         url: StrOrURL,
         *,
         method: str = hdrs.METH_GET,
-        protocols: Iterable[str] = (),
+        protocols: Collection[str] = (),
         timeout: Union[ClientWSTimeout, float, _SENTINEL, None] = sentinel,
         receive_timeout: Optional[float] = None,
         autoclose: bool = True,
@@ -1103,7 +1100,7 @@ def send(self, arg: None) -> "asyncio.Future[Any]":
         return self._coro.send(arg)
 
     def throw(self, arg: BaseException) -> None:  # type: ignore[override]
-        self._coro.throw(arg)
+        self._coro.throw(arg)  # type: ignore[unused-awaitable]
 
     def close(self) -> None:
         return self._coro.close()

diff --git a/aiohttp/client_proto.py b/aiohttp/client_proto.py
@@ -10,7 +10,7 @@
     ServerTimeoutError,
 )
 from .helpers import BaseTimerContext, set_exception, set_result
-from .http import HttpResponseParser, RawResponseMessage
+from .http import HttpResponseParser, RawResponseMessage, WebSocketReader
 from .streams import EMPTY_PAYLOAD, DataQueue, StreamReader
 
 
@@ -25,7 +25,7 @@ def __init__(self, loop: asyncio.AbstractEventLoop) -> None:
 
         self._payload: Optional[StreamReader] = None
         self._skip_payload = False
-        self._payload_parser = None
+        self._payload_parser: Optional[WebSocketReader] = None
 
         self._timer = None
 
@@ -46,7 +46,7 @@ def upgraded(self) -> bool:
 
     @property
     def should_close(self) -> bool:
-        if self._payload is not None and not self._payload.is_eof() or self._upgraded:
+        if self._payload is not None and not self._payload.is_eof():
             return True
 
         return (

diff --git a/aiohttp/client_reqrep.py b/aiohttp/client_reqrep.py
@@ -76,7 +76,7 @@
 try:
     import cchardet as chardet
 except ImportError:  # pragma: no cover
-    import charset_normalizer as chardet  # type: ignore[no-redef]
+    import charset_normalizer as chardet
 
 
 __all__ = ("ClientRequest", "ClientResponse", "RequestInfo", "Fingerprint")
@@ -697,7 +697,7 @@ def __init__(
         *,
         writer: "asyncio.Task[None]",
         continue100: Optional["asyncio.Future[bool]"],
-        timer: BaseTimerContext,
+        timer: Optional[BaseTimerContext],
         request_info: RequestInfo,
         traces: List["Trace"],
         loop: asyncio.AbstractEventLoop,
@@ -922,7 +922,7 @@ def close(self) -> None:
             return
 
         self._closed = True
-        if self._loop is None or self._loop.is_closed():
+        if self._loop.is_closed():
             return
 
         if self._connection is not None:
@@ -974,7 +974,8 @@ def _cleanup_writer(self) -> None:
 
     def _notify_content(self) -> None:
         content = self.content
-        if content and content.exception() is None:
+        # content can be None here, but the types are cheated elsewhere.
+        if content and content.exception() is None:  # type: ignore[truthy-bool]
             content.set_exception(ClientConnectionError("Connection closed"))
         self._released = True
 

diff --git a/aiohttp/client_ws.py b/aiohttp/client_ws.py
@@ -107,7 +107,7 @@ def _send_heartbeat(self) -> None:
             # fire-and-forget a task is not perfect but maybe ok for
             # sending ping. Otherwise we need a long-living heartbeat
             # task in the class.
-            self._loop.create_task(self._writer.ping())
+            self._loop.create_task(self._writer.ping())  # type: ignore[unused-awaitable]
 
             if self._pong_response_cb is not None:
                 self._pong_response_cb.cancel()
@@ -280,7 +280,8 @@ async def receive(self, timeout: Optional[float] = None) -> WSMessage:
             if msg.type == WSMsgType.CLOSE:
                 self._closing = True
                 self._close_code = msg.data
-                if not self._closed and self._autoclose:
+                # Could be closed elsewhere while awaiting reader
+                if not self._closed and self._autoclose:  # type: ignore[redundant-expr]
                     await self.close()
             elif msg.type == WSMsgType.CLOSING:
                 self._closing = True

diff --git a/aiohttp/connector.py b/aiohttp/connector.py
@@ -961,7 +961,7 @@ async def _wrap_create_connection(
             async with ceil_timeout(
                 timeout.sock_connect, ceil_threshold=timeout.ceil_threshold
             ):
-                return await self._loop.create_connection(*args, **kwargs)  # type: ignore[return-value]  # noqa
+                return await self._loop.create_connection(*args, **kwargs)
         except cert_errors as exc:
             raise ClientConnectorCertificateError(req.connection_key, exc) from exc
         except ssl_errors as exc:
@@ -1355,7 +1355,7 @@ async def _create_connection(
             async with ceil_timeout(
                 timeout.sock_connect, ceil_threshold=timeout.ceil_threshold
             ):
-                _, proto = await self._loop.create_pipe_connection(  # type: ignore[attr-defined] # noqa: E501
+                _, proto = await self._loop.create_pipe_connection(  # type: ignore[attr-defined]
                     self._factory, self._path
                 )
                 # the drain is required so that the connection_made is called

diff --git a/aiohttp/helpers.py b/aiohttp/helpers.py
@@ -587,7 +587,7 @@ def _weakref_handle(info: "Tuple[weakref.ref[object], str]") -> None:
 def weakref_handle(
     ob: object,
     name: str,
-    timeout: float,
+    timeout: Optional[float],
     loop: asyncio.AbstractEventLoop,
     timeout_ceil_threshold: float = 5,
 ) -> Optional[asyncio.TimerHandle]:
@@ -602,7 +602,7 @@ def weakref_handle(
 
 def call_later(
     cb: Callable[[], Any],
-    timeout: float,
+    timeout: Optional[float],
     loop: asyncio.AbstractEventLoop,
     timeout_ceil_threshold: float = 5,
 ) -> Optional[asyncio.TimerHandle]:
@@ -716,7 +716,7 @@ def __exit__(
         exc_tb: Optional[TracebackType],
     ) -> Optional[bool]:
         if self._tasks:
-            self._tasks.pop()
+            self._tasks.pop()  # type: ignore[unused-awaitable]
 
         if exc_type is asyncio.CancelledError and self._cancelled:
             raise asyncio.TimeoutError from None
@@ -762,7 +762,7 @@ def _parse_content_type(self, raw: str) -> None:
         else:
             msg = HeaderParser().parsestr("Content-Type: " + raw)
             self._content_type = msg.get_content_type()
-            params = msg.get_params()
+            params = msg.get_params(())
             self._content_dict = dict(params[1:])  # First element is content type again
 
     @property
@@ -823,8 +823,11 @@ def __init__(self, name: str, t: Optional[Type[_T]] = None):
                 module: str = frame.f_globals["__name__"]
                 break
             frame = frame.f_back
+        else:
+            raise RuntimeError("Failed to get module name.")
 
-        self._name = module + "." + name
+        # https://github.com/python/mypy/issues/14209
+        self._name = module + "." + name  # type: ignore[possibly-undefined]
         self._t = t
 
     def __lt__(self, other: object) -> bool:

diff --git a/aiohttp/http_parser.py b/aiohttp/http_parser.py
@@ -895,7 +895,8 @@ def feed_eof(self) -> None:
 
         if chunk or self.size > 0:
             self.out.feed_data(chunk, len(chunk))
-            if self.encoding == "deflate" and not self.decompressor.eof:  # type: ignore
+            # decompressor is not brotli unless encoding is "br"
+            if self.encoding == "deflate" and not self.decompressor.eof:  # type: ignore[union-attr]
                 raise ContentEncodingError("deflate")
 
         self.out.feed_eof()

diff --git a/aiohttp/http_websocket.py b/aiohttp/http_websocket.py
@@ -669,7 +669,7 @@ async def _send_frame(
             await self.protocol._drain_helper()
 
     def _write(self, data: bytes) -> None:
-        if self.transport is None or self.transport.is_closing():
+        if self.transport.is_closing():
             raise ConnectionResetError("Cannot write to closing transport")
         self.transport.write(data)
 

diff --git a/aiohttp/multipart.py b/aiohttp/multipart.py
@@ -441,8 +441,8 @@ async def release(self) -> None:
     async def text(self, *, encoding: Optional[str] = None) -> str:
         """Like read(), but assumes that body part contains text data."""
         data = await self.read(decode=True)
-        # see https://www.w3.org/TR/html5/forms.html#multipart/form-data-encoding-algorithm # NOQA
-        # and https://dvcs.w3.org/hg/xhr/raw-file/tip/Overview.html#dom-xmlhttprequest-send # NOQA
+        # see https://www.w3.org/TR/html5/forms.html#multipart/form-data-encoding-algorithm
+        # and https://dvcs.w3.org/hg/xhr/raw-file/tip/Overview.html#dom-xmlhttprequest-send
         encoding = encoding or self.get_charset(default="utf-8")
         return data.decode(encoding)
 

diff --git a/aiohttp/streams.py b/aiohttp/streams.py
@@ -66,9 +66,7 @@ def __aiter__(self) -> AsyncStreamIterator[bytes]:
 
     def iter_chunked(self, n: int) -> AsyncStreamIterator[bytes]:
         """Returns an asynchronous iterator that yields chunks of size n."""
-        return AsyncStreamIterator(
-            lambda: self.read(n)  # type: ignore[attr-defined,no-any-return]
-        )
+        return AsyncStreamIterator(lambda: self.read(n))  # type: ignore[attr-defined]
 
     def iter_any(self) -> AsyncStreamIterator[bytes]:
         """Yield all available data as soon as it is received."""

diff --git a/aiohttp/web_fileresponse.py b/aiohttp/web_fileresponse.py
@@ -167,14 +167,13 @@ async def prepare(self, request: "BaseRequest") -> Optional[AbstractStreamWriter
         ):
             return await self._not_modified(request, etag_value, last_modified)
 
+        ct = None
         if hdrs.CONTENT_TYPE not in self.headers:
             ct, encoding = mimetypes.guess_type(str(filepath))
             if not ct:
                 ct = "application/octet-stream"
-            should_set_ct = True
         else:
             encoding = "gzip" if gzip else None
-            should_set_ct = False
 
         status = self._status
         file_size = st.st_size
@@ -250,8 +249,8 @@ async def prepare(self, request: "BaseRequest") -> Optional[AbstractStreamWriter
                 # return a HTTP 206 for a Range request.
                 self.set_status(status)
 
-        if should_set_ct:
-            self.content_type = ct  # type: ignore[assignment]
+        if ct:
+            self.content_type = ct
         if encoding:
             self.headers[hdrs.CONTENT_ENCODING] = encoding
         if gzip:

diff --git a/aiohttp/web_protocol.py b/aiohttp/web_protocol.py
@@ -186,7 +186,7 @@ def __init__(
         tcp_keepalive: bool = True,
         logger: Logger = server_logger,
         access_log_class: _AnyAbstractAccessLogger = AccessLogger,
-        access_log: Logger = access_logger,
+        access_log: Optional[Logger] = access_logger,
         access_log_format: str = AccessLogger.LOG_FORMAT,
         max_line_size: int = 8190,
         max_field_size: int = 8190,
@@ -545,7 +545,8 @@ async def start(self) -> None:
 
                 # Drop the processed task from asyncio.Task.all_tasks() early
                 del task
-                if reset:
+                # https://github.com/python/mypy/issues/14309
+                if reset:  # type: ignore[possibly-undefined]
                     self.log_debug("Ignored premature client disconnection 2")
                     break
 
@@ -555,7 +556,8 @@ async def start(self) -> None:
                 # check payload
                 if not payload.is_eof():
                     lingering_time = self._lingering_time
-                    if not self._force_close and lingering_time:
+                    # Could be force closed while awaiting above tasks.
+                    if not self._force_close and lingering_time:  # type: ignore[redundant-expr]
                         self.log_debug(
                             "Start lingering close timer for %s sec.", lingering_time
                         )

diff --git a/aiohttp/web_response.py b/aiohttp/web_response.py
@@ -287,7 +287,7 @@ def etag(self, value: Optional[Union[ETag, str]]) -> None:
         elif isinstance(value, str):
             validate_etag_value(value)
             self._headers[hdrs.ETAG] = f'"{value}"'
-        elif isinstance(value, ETag) and isinstance(value.value, str):
+        elif isinstance(value, ETag) and isinstance(value.value, str):  # type: ignore[redundant-expr]
             validate_etag_value(value.value)
             hdr_value = f'W/"{value.value}"' if value.is_weak else f'"{value.value}"'
             self._headers[hdrs.ETAG] = hdr_value
@@ -605,9 +605,7 @@ def text(self) -> Optional[str]:
 
     @text.setter
     def text(self, text: str) -> None:
-        assert text is None or isinstance(
-            text, str
-        ), "text argument must be str (%r)" % type(text)
+        assert isinstance(text, str), "text argument must be str (%r)" % type(text)
 
         if self.content_type == "application/octet-stream":
             self.content_type = "text/plain"

diff --git a/aiohttp/web_ws.py b/aiohttp/web_ws.py
@@ -138,11 +138,11 @@ def _reset_heartbeat(self) -> None:
 
     def _send_heartbeat(self) -> None:
         if self._heartbeat is not None and not self._closed:
-            assert self._loop is not None
+            assert self._loop is not None and self._writer is not None
             # fire-and-forget a task is not perfect but maybe ok for
             # sending ping. Otherwise we need a long-living heartbeat
             # task in the class.
-            self._loop.create_task(self._writer.ping())  # type: ignore[union-attr]
+            self._loop.create_task(self._writer.ping())  # type: ignore[unused-awaitable]
 
             if self._pong_response_cb is not None:
                 self._pong_response_cb.cancel()
@@ -469,7 +469,8 @@ async def receive(self, timeout: Optional[float] = None) -> WSMessage:
             if msg.type == WSMsgType.CLOSE:
                 self._closing = True
                 self._close_code = msg.data
-                if not self._closed and self._autoclose:
+                # Could be closed while awaiting reader.
+                if not self._closed and self._autoclose:  # type: ignore[redundant-expr]
                     await self.close()
             elif msg.type == WSMsgType.CLOSING:
                 self._closing = True

diff --git a/examples/background_tasks.py b/examples/background_tasks.py
@@ -30,9 +30,9 @@ async def on_shutdown(app: web.Application) -> None:
 
 
 async def listen_to_redis(app: web.Application) -> None:
+    sub = await aioredis.Redis(host="localhost", port=6379)
+    ch, *_ = await sub.subscribe("news")
     try:
-        sub = await aioredis.Redis(host="localhost", port=6379)
-        ch, *_ = await sub.subscribe("news")
         async for msg in ch.iter(encoding="utf-8"):
             # Forward message to all connected websockets:
             for ws in app[websockets]:

diff --git a/requirements/constraints.txt b/requirements/constraints.txt
@@ -104,7 +104,7 @@ multidict==6.0.4
     # via
     #   -r requirements/multidict.txt
     #   yarl
-mypy==0.982 ; implementation_name == "cpython"
+mypy==1.4.1 ; implementation_name == "cpython"
     # via
     #   -r requirements/lint.txt
     #   -r requirements/test.txt

diff --git a/requirements/lint.txt b/requirements/lint.txt
@@ -1,6 +1,6 @@
 -r typing-extensions.txt
 aioredis==2.0.1
-mypy==0.982; implementation_name=="cpython"
+mypy==1.4.1; implementation_name=="cpython"
 pre-commit==3.3.3
 pytest==7.4.0
 slotscheck==0.8.0