fix(worker): Depend on typed SAQ

pyproject.toml

@@ -56,7 +56,7 @@ httpx = "*"
 orjson = "*"
 pydantic = "*"
 redis = "*"
-saq = "*"
+saq = { git = "https://github.com/tobymao/saq.git" }
 sentry-sdk = "*"
 sqlalchemy = "==2.0.0b2"
 starlite = "~=1.32"

src/starlite_saqlalchemy/worker.py

@@ -2,13 +2,16 @@
 import asyncio
 from collections import abc
 from functools import partial
-from typing import Any
+from typing import TYPE_CHECKING, Any
 
 import orjson
-import saq  # type:ignore[import]
+import saq
 
 from . import redis
 
+if TYPE_CHECKING:
+    from signal import Signals
+
 __all__ = [
     "Queue",
     "Worker",
@@ -20,7 +23,7 @@
 WorkerFunction = abc.Callable[..., abc.Awaitable[Any]]
 
 
-class Queue(saq.Queue):  # type:ignore[misc]
+class Queue(saq.Queue):
     """[SAQ Queue](https://github.com/tobymao/saq/blob/master/saq/queue.py)
 
     Configures `orjson` for JSON serialization/deserialization if not otherwise configured.
@@ -39,11 +42,11 @@ def __init__(self, *args: Any, **kwargs: Any) -> None:
         super().__init__(*args, **kwargs)
 
 
-class Worker(saq.Worker):  # type:ignore[misc]
+class Worker(saq.Worker):
     """Modify behavior of saq worker for orchestration by Starlite."""
 
     # same issue: https://github.com/samuelcolvin/arq/issues/182
-    SIGNALS: list[str] = []
+    SIGNALS: list["Signals"] = []
 
     async def on_app_startup(self) -> None:
         """Attach the worker to the running event loop."""
@@ -59,7 +62,7 @@ async def on_app_startup(self) -> None:
 
 
 def create_worker_instance(
-    functions: abc.Iterable[WorkerFunction | tuple[str, WorkerFunction]]
+    functions: abc.Collection[WorkerFunction | tuple[str, WorkerFunction]]
 ) -> Worker:
     """