fix: misconfiguration with slots

fix: misconfiguration with slots

Author: cofin

litestar_saq/config.py

@@ -43,11 +43,10 @@ def _get_static_files() -> Path:
 
 @dataclass
 class TaskQueues:
-    __slots__ = ("_queues",)
-    _queues: dict[str, TaskQueue] = field(default_factory=dict)
+    queues: dict[str, TaskQueue] = field(default_factory=dict)
 
     def get(self, name: str) -> TaskQueue:
-        queue = self._queues.get(name)
+        queue = self.queues.get(name)
         if queue is not None:
             return queue
         msg = "Could not find the specified queue.  Please check your configuration."
@@ -156,7 +155,7 @@ def get_queues(self) -> TaskQueues:
             Dictionary of queues.
         """
         if self.queue_instances is not None:
-            return TaskQueues(_queues=self.queue_instances)
+            return TaskQueues(queues=self.queue_instances)
         self.queue_instances = {}
         for queue_config in self.queue_configs:
             self.queue_instances[queue_config.name] = Queue(
@@ -167,7 +166,7 @@ def get_queues(self) -> TaskQueues:
                 load=self.json_deserializer,
                 max_concurrent_ops=queue_config.max_concurrent_ops,
             )
-        return TaskQueues(_queues=self.queue_instances)
+        return TaskQueues(queues=self.queue_instances)
 
     def create_app_state_items(self) -> dict[str, Any]:
         """Key/value pairs to be stored in application state."""

litestar_saq/plugin.py

@@ -78,7 +78,7 @@ def get_workers(self) -> list[Worker]:
         self._worker_instances = []
         self._worker_instances.extend(
             Worker(
-                queue=self._get_queue(queue_config.name, queues._queues),  # noqa: SLF001
+                queue=self._get_queue(queue_config.name, queues.queues),
                 functions=queue_config.tasks,
                 cron_jobs=queue_config.scheduled_tasks,
                 concurrency=queue_config.concurrency,

pyproject.toml

@@ -30,7 +30,7 @@ license = {text = "MIT"}
 name = "litestar-saq"
 readme = "README.md"
 requires-python = ">=3.8"
-version = "0.1.4"
+version = "0.1.5"
 
 [project.urls]
 Changelog = "https://cofin.github.io/litesatr-saq/latest/changelog"