linter fixups after worker settings fixing

Author: AlanCoding

dispatcher/config.py

@@ -16,12 +16,7 @@ def __init__(self, config: dict) -> None:
         # self.options: dict = config.get('options', {})
 
     def serialize(self):
-        return dict(
-            brokers=self.brokers,
-            producers=self.producers,
-            service=self.service,
-            publish=self.publish
-        )
+        return dict(brokers=self.brokers, producers=self.producers, service=self.service, publish=self.publish)
 
 
 def settings_from_file(path: str) -> DispatcherSettings:

dispatcher/main.py

@@ -5,9 +5,10 @@
 from types import SimpleNamespace
 from typing import Iterable, Optional
 
+from dispatcher.config import LazySettings
+from dispatcher.config import settings as global_settings
 from dispatcher.pool import WorkerPool
 from dispatcher.producers import BaseProducer
-from dispatcher.config import settings as global_settings, LazySettings
 
 logger = logging.getLogger(__name__)
 

dispatcher/pool.py

@@ -4,9 +4,10 @@
 from asyncio import Task
 from typing import Iterator, Optional
 
+from dispatcher.config import LazySettings
+from dispatcher.config import settings as global_settings
 from dispatcher.process import ProcessManager, ProcessProxy
 from dispatcher.utils import DuplicateBehavior, MessageAction
-from dispatcher.config import settings as global_settings, LazySettings
 
 logger = logging.getLogger(__name__)
 
@@ -188,7 +189,12 @@ async def manage_timeout(self) -> None:
             self.events.timeout_event.clear()
 
     async def up(self) -> None:
-        process = self.process_manager.create_process((self.settings_stash, self.next_worker_id,))
+        process = self.process_manager.create_process(
+            (
+                self.settings_stash,
+                self.next_worker_id,
+            )
+        )
         worker = PoolWorker(self.next_worker_id, process)
         self.workers[self.next_worker_id] = worker
         self.next_worker_id += 1

dispatcher/process.py

@@ -46,7 +46,7 @@ def get_event_loop(self):
             self._loop = asyncio.get_event_loop()
         return self._loop
 
-    def create_process(self, args: Iterable[int | str], **kwargs) -> ProcessProxy:
+    def create_process(self, args: Iterable[int | str | dict], **kwargs) -> ProcessProxy:
         return ProcessProxy(args, self.finished_queue, **kwargs)
 
     async def read_finished(self) -> dict[str, Union[str, int]]:

dispatcher/registry.py

@@ -6,8 +6,9 @@
 from typing import Callable, Optional, Set, Tuple
 from uuid import uuid4
 
+from dispatcher.config import LazySettings
+from dispatcher.config import settings as global_settings
 from dispatcher.utils import MODULE_METHOD_DELIMITER, DispatcherCallable, resolve_callable
-from dispatcher.config import settings as global_settings, DispatcherSettings
 
 logger = logging.getLogger(__name__)
 
@@ -80,7 +81,7 @@ def get_async_body(
 
         return body
 
-    def apply_async(self, args=None, kwargs=None, queue=None, uuid=None, settings: DispatcherSettings = global_settings, **kw) -> Tuple[dict, str]:
+    def apply_async(self, args=None, kwargs=None, queue=None, uuid=None, settings: LazySettings = global_settings, **kw) -> Tuple[dict, str]:
         queue = queue or self.submission_defaults.get('queue')
 
         if callable(queue):

dispatcher/worker/task.py

@@ -8,8 +8,8 @@
 import traceback
 from queue import Empty as QueueEmpty
 
-from dispatcher.registry import registry
 from dispatcher.config import setup
+from dispatcher.registry import registry
 
 logger = logging.getLogger(__name__)