fix: qa warns from pyright

Author: manawasp

mode/locals.py

@@ -93,7 +93,7 @@ class XProxy(MutableMappingRole, AsyncContextManagerRole):
 )
 from contextlib import AbstractAsyncContextManager, AbstractContextManager
 from functools import wraps
-from types import GetSetDescriptorType, TracebackType
+from types import CoroutineType, GetSetDescriptorType, TracebackType
 from typing import (
     Any,
     Callable,
@@ -479,21 +479,21 @@ def _get_generator(self) -> AsyncGenerator[T_co, T_contra]:
         obj = self._get_current_object()  # type: ignore
         return cast(AsyncGenerator[T_co, T_contra], obj)
 
-    def __anext__(self) -> Awaitable[T_co]:
+    def __anext__(self) -> CoroutineType[Any, Any, T_co]:
         return self._get_generator().__anext__()
 
-    def asend(self, value: T_contra) -> Awaitable[T_co]:
+    def asend(self, value: T_contra) -> CoroutineType[Any, Any, T_co]:
         return self._get_generator().asend(value)
 
     def athrow(
         self,
         typ: type[BaseException],
         val: Optional[BaseException] = None,
         tb: Optional[TracebackType] = None,
-    ) -> Awaitable[T_co]:
+    ) -> CoroutineType[Any, Any, T_co]:
         return self._get_generator().athrow(typ, val, tb)
 
-    def aclose(self) -> Awaitable[None]:
+    def aclose(self) -> CoroutineType[Any, Any, None]:
         return self._get_generator().aclose()
 
     def __aiter__(self) -> AsyncGenerator[T_co, T_contra]:
@@ -514,7 +514,7 @@ def _get_sequence(self) -> Sequence[T_co]:
         return cast(Sequence[T_co], obj)
 
     @overload
-    def __getitem__(self, i: int) -> T_co: ...
+    def __getitem__(self, s: int) -> T_co: ...
 
     @overload
     def __getitem__(self, s: slice) -> MutableSequence[T_co]: ...
@@ -556,13 +556,13 @@ def insert(self, index: int, object: T) -> None:
         self._get_sequence().insert(index, object)
 
     @overload
-    def __setitem__(self, i: int, o: T) -> None: ...
+    def __setitem__(self, s: int, o: T) -> None: ...
 
     @overload
     def __setitem__(self, s: slice, o: Iterable[T]) -> None: ...
 
-    def __setitem__(self, index_or_slice: Any, o: Any) -> None:
-        self._get_sequence().__setitem__(index_or_slice, o)
+    def __setitem__(self, s: Any, o: Any) -> None:
+        self._get_sequence().__setitem__(s, o)
 
     @overload
     def __delitem__(self, i: int) -> None: ...
@@ -708,19 +708,19 @@ class ContextManagerProxy(
 class AsyncContextManagerRole(AbstractAsyncContextManager[T_co]):
     """Role/Mixin for `contextlib.AbstractAsyncContextManager` proxy methods."""
 
-    def __aenter__(self) -> Awaitable[T_co]:
+    def __aenter__(self) -> CoroutineType[Any, Any, T_co]:
         obj = self._get_current_object()  # type: ignore
-        return cast(Awaitable[T_co], obj.__aenter__())
+        return cast(CoroutineType[Any, Any, T_co], obj.__aenter__())
 
     def __aexit__(
         self,
         exc_type: Optional[type[BaseException]],
         exc_value: Optional[BaseException],
         traceback: Optional[TracebackType],
-    ) -> Awaitable[Optional[bool]]:
+    ) -> CoroutineType[Any, Any, Optional[bool]]:
         obj = self._get_current_object()  # type: ignore
         val = obj.__aexit__(exc_type, exc_value, traceback)
-        return cast(Awaitable[Optional[bool]], val)
+        return cast(CoroutineType[Any, Any, Optional[bool]], val)
 
 
 class AsyncContextManagerProxy(

mode/signals.py

@@ -5,7 +5,7 @@
 from collections.abc import Iterable, Mapping, MutableSet
 from functools import partial
 from types import MethodType
-from typing import Any, Callable, Optional, cast, no_type_check
+from typing import Any, Callable, Optional, Union, cast, no_type_check
 from weakref import ReferenceType, WeakMethod, ref
 
 from .types.signals import (
@@ -16,7 +16,6 @@
     SignalT,
     SyncSignalT,
     T,
-    T_contra,
 )
 from .utils.futures import maybe_async
 
@@ -37,7 +36,7 @@ def __init__(
         loop: Optional[asyncio.AbstractEventLoop] = None,
         default_sender: Any = None,
         receivers: Optional[MutableSet[SignalHandlerRefT]] = None,
-        filter_receivers: FilterReceiverMapping = None,
+        filter_receivers: Union[FilterReceiverMapping, None] = None,
     ) -> None:
         self.name = name or ""
         self.owner = owner
@@ -84,7 +83,7 @@ class X(Service):
             starting = Signal()
 
         >>> X.starting
-        <Signal: X.strting>
+        <Signal: X.string>
         ```
         """
         if not self.name:
@@ -94,15 +93,18 @@ class X(Service):
     def unpack_sender_from_args(self, *args: Any) -> tuple[T, tuple[Any, ...]]:
         sender = self.default_sender
         if sender is None:
-            if not args:
+            if not args or len(args) == 0:
                 raise TypeError("Signal.send requires at least one argument")
+
             if len(args) > 1:
                 sender, *args = args  # type: ignore
             else:
                 sender, args = args[0], ()
         return sender, args
 
-    def connect(self, fun: SignalHandlerT = None, **kwargs: Any) -> Callable:
+    def connect(
+        self, fun: Union[SignalHandlerT, None] = None, **kwargs: Any
+    ) -> Callable:
         if fun is not None:
             return self._connect(fun, **kwargs)
         return partial(self._connect, **kwargs)
@@ -134,7 +136,7 @@ def disconnect(
             except ValueError:
                 pass
 
-    def iter_receivers(self, sender: T_contra) -> Iterable[SignalHandlerT]:
+    def iter_receivers(self, sender: object) -> Iterable[SignalHandlerT]:
         if self._receivers or self._filter_receivers:
             r = self._update_receivers(self._receivers)
             if sender is not None:

mode/worker.py

@@ -98,7 +98,7 @@ def __init__(
         loglevel: Optional[Union[str, int]] = None,
         logfile: Optional[Union[str, IO]] = None,
         redirect_stdouts: bool = True,
-        redirect_stdouts_level: logging.Severity = None,
+        redirect_stdouts_level: Optional[logging.Severity] = None,
         stdout: Optional[IO] = sys.stdout,
         stderr: Optional[IO] = sys.stderr,
         console_port: int = 50101,