@@ -7,20 +7,20 @@ from typing import Generic, NamedTuple, TypeVar
77
88import pika .connection
99from pika .adapters .utils import nbio_interface
10- from twisted .internet .base import DelayedCall # type: ignore[import-not-found] # pyright: ignore[reportMissingImports]
11- from twisted .internet .defer import ( # type: ignore[import-not-found] # pyright: ignore[reportMissingImports]
10+ from twisted .internet .base import DelayedCall
11+ from twisted .internet .defer import (
1212 Deferred ,
1313 DeferredQueue ,
1414)
15- from twisted .internet .interfaces import ITransport # type: ignore[import-not-found] # pyright: ignore[reportMissingImports]
16- from twisted .internet .protocol import Protocol # type: ignore[import-not-found] # pyright: ignore[reportMissingImports]
17- from twisted .python .failure import Failure # type: ignore[import-not-found] # pyright: ignore[reportMissingImports]
15+ from twisted .internet .interfaces import ITransport
16+ from twisted .internet .protocol import Protocol
17+ from twisted .python .failure import Failure
1818
1919_T = TypeVar ("_T" )
2020
2121LOGGER : Logger
2222
23- class ClosableDeferredQueue (DeferredQueue [_T ], Generic [_T ]): # pyright: ignore[reportUntypedBaseClass] # noqa: Y060
23+ class ClosableDeferredQueue (DeferredQueue [_T ], Generic [_T ]):
2424 closed : Failure | BaseException | None
2525 def __init__ (self , size : Incomplete | None = ..., backlog : Incomplete | None = ...) -> None : ...
2626 # Returns a Deferred with an error if fails. None if success
@@ -130,7 +130,7 @@ class _TwistedConnectionAdapter(pika.connection.Connection):
130130 def connection_lost (self , error : Exception ) -> None : ...
131131 def data_received (self , data ) -> None : ...
132132
133- class TwistedProtocolConnection (Protocol ): # pyright: ignore[reportUntypedBaseClass]
133+ class TwistedProtocolConnection (Protocol ):
134134 ready : Deferred [None ] | None
135135 closed : Deferred [None ] | Failure | BaseException | None
136136 def __init__ (self , parameters : Incomplete | None = ..., custom_reactor : Incomplete | None = ...) -> None : ...
0 commit comments