1010 TypeVar ,
1111)
1212
13+ from typing_extensions import Self
14+
1315from repid .config import Config
1416from repid .message import MessageCategory
1517from repid .middlewares import middleware_wrapper
@@ -26,10 +28,10 @@ class _WrappedABC(ABC): # noqa: B024
2628 __WRAPPED_METHODS__ : tuple [str , ...] = ()
2729
2830 def __new__ (
29- cls : type [ WrappedABCSelf ] ,
30- * args : Any , # noqa: ARG003
31- ** kwargs : Any , # noqa: ARG003
32- ) -> WrappedABCSelf :
31+ cls ,
32+ * args : Any ,
33+ ** kwargs : Any ,
34+ ) -> Self :
3335 inst = super ().__new__ (cls )
3436
3537 for method in inst .__WRAPPED_METHODS__ :
@@ -184,7 +186,7 @@ async def queue_delete(self, queue_name: str) -> None:
184186
185187 def __new__ ( # noqa: PYI034
186188 cls : type [MessageBrokerT ],
187- * args : Any , # noqa: ARG003
189+ * args : Any ,
188190 ** kwargs : Any , # noqa: ARG003s
189191 ) -> MessageBrokerT :
190192 cls .ROUTING_KEY_CLASS = deepcopy (Config .ROUTING_KEY )
@@ -222,8 +224,8 @@ async def delete_bucket(self, id_: str) -> None:
222224
223225 def __new__ ( # noqa: PYI034
224226 cls : type [BucketBrokerT ],
225- * args : Any , # noqa: ARG003
226- ** kwargs : Any , # noqa: ARG003
227+ * args : Any ,
228+ ** kwargs : Any ,
227229 ) -> BucketBrokerT :
228230 cls .BUCKET_CLASS = deepcopy (Config .BUCKET )
229231
0 commit comments