From 5f1e83e7413583294aecc8dd9fa5b465d46ee77f Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Tue, 7 Mar 2023 17:09:43 -0500 Subject: [PATCH] More single doc-strs in discovery mod --- tractor/_discovery.py | 14 ++++++++++---- tractor/_runtime.py | 1 + 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/tractor/_discovery.py b/tractor/_discovery.py index b6957ba..03775ac 100644 --- a/tractor/_discovery.py +++ b/tractor/_discovery.py @@ -41,8 +41,10 @@ async def get_arbiter( port: int, ) -> AsyncGenerator[Union[Portal, LocalPortal], None]: - '''Return a portal instance connected to a local or remote + ''' + Return a portal instance connected to a local or remote arbiter. + ''' actor = current_actor() @@ -134,12 +136,16 @@ async def find_actor( @acm async def wait_for_actor( name: str, - arbiter_sockaddr: tuple[str, int] | None = None + arbiter_sockaddr: tuple[str, int] | None = None, + # registry_addr: tuple[str, int] | None = None, + ) -> AsyncGenerator[Portal, None]: - """Wait on an actor to register with the arbiter. + ''' + Wait on an actor to register with the arbiter. A portal to the first registered actor is returned. - """ + + ''' actor = current_actor() async with get_arbiter( diff --git a/tractor/_runtime.py b/tractor/_runtime.py index 707b9dd..06bc34f 100644 --- a/tractor/_runtime.py +++ b/tractor/_runtime.py @@ -825,6 +825,7 @@ class Actor: 1, f'\n*** No stream open on `{self.uid[0]}` side! ***\n' ) + text = '\n'.join(lines) if ctx._backpressure: