diff --git a/tractor/_actor.py b/tractor/_actor.py index 03ff833..02a010c 100644 --- a/tractor/_actor.py +++ b/tractor/_actor.py @@ -821,7 +821,7 @@ class Actor: self._server_down = trio.Event() try: async with trio.open_nursery() as server_n: - listeners: List[trio.abc.Listener] = await server_n.start( + l: List[trio.abc.Listener] = await server_n.start( partial( trio.serve_tcp, self._stream_handler, @@ -832,9 +832,10 @@ class Actor: host=accept_host, ) ) - log.debug("Started tcp server(s) on" # type: ignore - f" {[l.socket for l in listeners]}") - self._listeners.extend(listeners) + log.debug( + "Started tcp server(s) on" + f" {[getattr(l, 'socket', 'unknown socket') for l in l]}") + self._listeners.extend(l) task_status.started(server_n) finally: # signal the server is down since nursery above terminated diff --git a/tractor/_entry.py b/tractor/_entry.py index a9b91e4..0faf486 100644 --- a/tractor/_entry.py +++ b/tractor/_entry.py @@ -15,7 +15,7 @@ log = get_logger(__name__) def _mp_main( - actor: 'Actor', # noqa + actor: 'Actor', # type: ignore accept_addr: Tuple[str, int], forkserver_info: Tuple[Any, Any, Any, Any, Any], start_method: str, @@ -54,8 +54,9 @@ def _mp_main( def _trio_main( - actor: 'Actor', # noqa - parent_addr: Tuple[str, int] = None + actor: 'Actor', # type: ignore + *, + parent_addr: Tuple[str, int] = None, ) -> None: """Entry point for a `trio_run_in_process` subactor. """