use the generic type checker ignore syntax instead of pyright

Author: rthalley

dns/_asyncio_backend.py

@@ -131,7 +131,7 @@ async def getpeercert(self, timeout):
     import httpx
 
     _CoreAsyncNetworkBackend = httpcore.AsyncNetworkBackend
-    _CoreAnyIOStream = httpcore._backends.anyio.AnyIOStream  # pyright: ignore
+    _CoreAnyIOStream = httpcore._backends.anyio.AnyIOStream  # type: ignore
 
     from dns.query import _compute_times, _expiration_for_this_attempt, _remaining
 
@@ -234,7 +234,7 @@ async def make_socket(
                 # proper fix for [#637].
                 source = (dns.inet.any_for_af(af), 0)
             transport, protocol = await loop.create_datagram_endpoint(
-                _DatagramProtocol,  # pyright: ignore
+                _DatagramProtocol,  # type: ignore
                 source,
                 family=af,
                 proto=proto,

dns/_immutable_ctx.py

@@ -41,7 +41,7 @@ def nf(*args, **kwargs):
         finally:
             _in__init__.reset(previous)
 
-    nf.__signature__ = inspect.signature(f)  # pyright: ignore
+    nf.__signature__ = inspect.signature(f)  # type: ignore
     return nf
 
 

dns/asyncquery.py

@@ -223,9 +223,9 @@ async def udp(
             dtuple = None
         cm = await backend.make_socket(af, socket.SOCK_DGRAM, 0, stuple, dtuple)
     async with cm as s:
-        await send_udp(s, wire, destination, expiration)  # pyright: ignore
+        await send_udp(s, wire, destination, expiration)  # type: ignore
         (r, received_time, _) = await receive_udp(
-            s,  # pyright: ignore
+            s,  # type: ignore
             destination,
             expiration,
             ignore_unexpected,
@@ -428,9 +428,9 @@ async def tcp(
             af, socket.SOCK_STREAM, 0, stuple, dtuple, timeout
         )
     async with cm as s:
-        await send_tcp(s, wire, expiration)  # pyright: ignore
+        await send_tcp(s, wire, expiration)  # type: ignore
         (r, received_time) = await receive_tcp(
-            s,  # pyright: ignore
+            s,  # type: ignore
             expiration,
             one_rr_per_rrset,
             q.keyring,
@@ -514,8 +514,8 @@ async def tls(
 
 
 def _maybe_get_resolver(
-    resolver: Optional["dns.asyncresolver.Resolver"],  # pyright: ignore
-) -> "dns.asyncresolver.Resolver":  # pyright: ignore
+    resolver: Optional["dns.asyncresolver.Resolver"],  # type: ignore
+) -> "dns.asyncresolver.Resolver":  # type: ignore
     # We need a separate method for this to avoid overriding the global
     # variable "dns" with the as-yet undefined local variable "dns"
     # in https().
@@ -541,7 +541,7 @@ async def https(
     post: bool = True,
     verify: bool | str | ssl.SSLContext = True,
     bootstrap_address: str | None = None,
-    resolver: Optional["dns.asyncresolver.Resolver"] = None,  # pyright: ignore
+    resolver: Optional["dns.asyncresolver.Resolver"] = None,  # type: ignore
     family: int = socket.AF_UNSPEC,
     http_version: HTTPVersion = HTTPVersion.DEFAULT,
 ) -> dns.message.Message:
@@ -586,14 +586,14 @@ async def https(
     ):
         if bootstrap_address is None:
             resolver = _maybe_get_resolver(resolver)
-            assert parsed.hostname is not None  # pyright: ignore
-            answers = await resolver.resolve_name(  # pyright: ignore
-                parsed.hostname, family  # pyright: ignore
+            assert parsed.hostname is not None  # type: ignore
+            answers = await resolver.resolve_name(  # type: ignore
+                parsed.hostname, family  # type: ignore
             )
             bootstrap_address = random.choice(list(answers.addresses()))
         if client and not isinstance(
             client, dns.quic.AsyncQuicConnection
-        ):  # pyright: ignore
+        ):  # type: ignore
             raise ValueError("client parameter must be a dns.quic.AsyncQuicConnection.")
         assert client is None or isinstance(client, dns.quic.AsyncQuicConnection)
         return await _http3(
@@ -614,7 +614,7 @@ async def https(
     if not have_doh:
         raise NoDOH  # pragma: no cover
     # pylint: disable=possibly-used-before-assignment
-    if client and not isinstance(client, httpx.AsyncClient):  # pyright: ignore
+    if client and not isinstance(client, httpx.AsyncClient):  # type: ignore
         raise ValueError("client parameter must be an httpx.AsyncClient")
     # pylint: enable=possibly-used-before-assignment
 
@@ -647,7 +647,7 @@ async def https(
             family=family,
         )
 
-        cm = httpx.AsyncClient(  # pyright: ignore
+        cm = httpx.AsyncClient(  # type: ignore
             http1=h1, http2=h2, verify=verify, transport=transport  # type: ignore
         )
 
@@ -662,7 +662,7 @@ async def https(
                 }
             )
             response = await backend.wait_for(
-                the_client.post(  # pyright: ignore
+                the_client.post(  # type: ignore
                     url,
                     headers=headers,
                     content=wire,
@@ -674,7 +674,7 @@ async def https(
             wire = base64.urlsafe_b64encode(wire).rstrip(b"=")
             twire = wire.decode()  # httpx does a repr() if we give it bytes
             response = await backend.wait_for(
-                the_client.get(  # pyright: ignore
+                the_client.get(  # type: ignore
                     url,
                     headers=headers,
                     params={"dns": twire},
@@ -743,11 +743,11 @@ async def _http3(
             if connection:
                 the_connection = connection
             else:
-                the_connection = the_manager.connect(  # pyright: ignore
+                the_connection = the_manager.connect(  # type: ignore
                     where, port, source, source_port
                 )
             (start, expiration) = _compute_times(timeout)
-            stream = await the_connection.make_stream(timeout)  # pyright: ignore
+            stream = await the_connection.make_stream(timeout)  # type: ignore
             async with stream:
                 # note that send_h3() does not need await
                 stream.send_h3(url, wire, post)
@@ -815,11 +815,11 @@ async def quic(
             server_name=server_hostname,
         ) as the_manager:
             if not connection:
-                the_connection = the_manager.connect(  # pyright: ignore
+                the_connection = the_manager.connect(  # type: ignore
                     where, port, source, source_port
                 )
             (start, expiration) = _compute_times(timeout)
-            stream = await the_connection.make_stream(timeout)  # pyright: ignore
+            stream = await the_connection.make_stream(timeout)  # type: ignore
             async with stream:
                 await stream.send(wire, True)
                 wire = await stream.receive(_remaining(expiration))
@@ -870,11 +870,11 @@ async def _inbound_xfr(
                 mexpiration = expiration
             if is_udp:
                 timeout = _timeout(mexpiration)
-                (rwire, _) = await udp_sock.recvfrom(65535, timeout)  # pyright: ignore
+                (rwire, _) = await udp_sock.recvfrom(65535, timeout)  # type: ignore
             else:
-                ldata = await _read_exactly(tcp_sock, 2, mexpiration)  # pyright: ignore
+                ldata = await _read_exactly(tcp_sock, 2, mexpiration)  # type: ignore
                 (l,) = struct.unpack("!H", ldata)
-                rwire = await _read_exactly(tcp_sock, l, mexpiration)  # pyright: ignore
+                rwire = await _read_exactly(tcp_sock, l, mexpiration)  # type: ignore
             r = dns.message.from_wire(
                 rwire,
                 keyring=query.keyring,
@@ -929,13 +929,13 @@ async def inbound_xfr(
         )
         async with s:
             try:
-                async for _ in _inbound_xfr(  # pyright: ignore
+                async for _ in _inbound_xfr(  # type: ignore
                     txn_manager,
                     s,
                     query,
                     serial,
                     timeout,
-                    expiration,  # pyright: ignore
+                    expiration,  # type: ignore
                 ):
                     pass
                 return
@@ -947,7 +947,7 @@ async def inbound_xfr(
         af, socket.SOCK_STREAM, 0, stuple, dtuple, _timeout(expiration)
     )
     async with s:
-        async for _ in _inbound_xfr(  # pyright: ignore
-            txn_manager, s, query, serial, timeout, expiration  # pyright: ignore
+        async for _ in _inbound_xfr(  # type: ignore
+            txn_manager, s, query, serial, timeout, expiration  # type: ignore
         ):
             pass

dns/dnssecalgs/cryptography.py

@@ -34,7 +34,7 @@ def to_pem(self) -> bytes:
 class CryptographyPrivateKey(GenericPrivateKey):
     key: Any = None
     key_cls: Any = None
-    public_cls: Type[CryptographyPublicKey]  # pyright: ignore
+    public_cls: Type[CryptographyPublicKey]  # type: ignore
 
     def __init__(self, key: Any) -> None:  # pylint: disable=super-init-not-called
         if self.key_cls is None:

dns/dnssecalgs/dsa.py

@@ -78,9 +78,7 @@ def sign(
         public_dsa_key = self.key.public_key()
         if public_dsa_key.key_size > 1024:
             raise ValueError("DSA key size overflow")
-        der_signature = self.key.sign(
-            data, self.public_cls.chosen_hash  # pyright: ignore
-        )
+        der_signature = self.key.sign(data, self.public_cls.chosen_hash)  # type: ignore
         dsa_r, dsa_s = utils.decode_dss_signature(der_signature)
         dsa_t = (public_dsa_key.key_size // 8 - 64) // 8
         octets = 20

dns/dnssecalgs/ecdsa.py

@@ -55,15 +55,15 @@ def sign(
     ) -> bytes:
         """Sign using a private key per RFC 6605, section 4."""
         algorithm = ec.ECDSA(
-            self.public_cls.chosen_hash,  # pyright: ignore
+            self.public_cls.chosen_hash,  # type: ignore
             deterministic_signing=deterministic,
         )
         der_signature = self.key.sign(data, algorithm)
         dsa_r, dsa_s = utils.decode_dss_signature(der_signature)
         signature = int.to_bytes(
-            dsa_r, length=self.public_cls.octets, byteorder="big"  # pyright: ignore
+            dsa_r, length=self.public_cls.octets, byteorder="big"  # type: ignore
         ) + int.to_bytes(
-            dsa_s, length=self.public_cls.octets, byteorder="big"  # pyright: ignore
+            dsa_s, length=self.public_cls.octets, byteorder="big"  # type: ignore
         )
         if verify:
             self.public_key().verify(signature, data)
@@ -73,7 +73,7 @@ def sign(
     def generate(cls) -> "PrivateECDSA":
         return cls(
             key=ec.generate_private_key(
-                curve=cls.public_cls.curve, backend=default_backend()  # pyright: ignore
+                curve=cls.public_cls.curve, backend=default_backend()  # type: ignore
             ),
         )
 

dns/dnssecalgs/eddsa.py

@@ -27,7 +27,7 @@ def from_dnskey(cls, key: DNSKEY) -> "PublicEDDSA":
 
 
 class PrivateEDDSA(CryptographyPrivateKey):
-    public_cls: Type[PublicEDDSA]  # pyright: ignore
+    public_cls: Type[PublicEDDSA]  # type: ignore
 
     def sign(
         self,

dns/dnssecalgs/rsa.py

@@ -64,7 +64,7 @@ def sign(
     ) -> bytes:
         """Sign using a private key per RFC 3110, section 3."""
         signature = self.key.sign(
-            data, padding.PKCS1v15(), self.public_cls.chosen_hash  # pyright: ignore
+            data, padding.PKCS1v15(), self.public_cls.chosen_hash  # type: ignore
         )
         if verify:
             self.public_key().verify(signature, data)

dns/enum.py

@@ -25,9 +25,9 @@ class IntEnum(enum.IntEnum):
     @classmethod
     def _missing_(cls, value):
         cls._check_value(value)
-        val = int.__new__(cls, value)  # pyright: ignore
+        val = int.__new__(cls, value)  # type: ignore
         val._name_ = cls._extra_to_text(value, None) or f"{cls._prefix()}{value}"
-        val._value_ = value  # pyright: ignore
+        val._value_ = value  # type: ignore
         return val
 
     @classmethod

dns/message.py

@@ -1103,7 +1103,7 @@ def _message_factory_from_opcode(opcode):
         return QueryMessage
     elif opcode == dns.opcode.UPDATE:
         _maybe_import_update()
-        return dns.update.UpdateMessage  # pyright: ignore
+        return dns.update.UpdateMessage  # type: ignore
     else:
         return Message
 
@@ -1207,7 +1207,7 @@ def _get_section(self, section_number, count):
                 else:
                     with self.parser.restrict_to(rdlen):
                         rd = dns.rdata.from_wire_parser(
-                            rdclass,  # pyright: ignore
+                            rdclass,  # type: ignore
                             rdtype,
                             self.parser,
                             self.message.origin,
@@ -1249,7 +1249,7 @@ def _get_section(self, section_number, count):
                     rrset = self.message.find_rrset(
                         section,
                         name,
-                        rdclass,  # pyright: ignore
+                        rdclass,  # type: ignore
                         rdtype,
                         covers,
                         deleting,