jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

More single doc-strs in discovery mod

proper_breakpoint_hooking
Tyler Goodlet 2023-03-07 17:09:43 -05:00
parent ea2cc9ec75
commit 5f1e83e741
2 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tractor/_discovery.py
View File

@ -41,8 +41,10 @@ async def get_arbiter(
port: int, port: int,
) -> AsyncGenerator[Union[Portal, LocalPortal], None]: ) -> 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. arbiter.
''' '''
actor = current_actor() actor = current_actor()
@ -134,12 +136,16 @@ async def find_actor(
@acm @acm
async def wait_for_actor( async def wait_for_actor(
name: str, 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]: ) -> 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. A portal to the first registered actor is returned.
"""
'''
actor = current_actor() actor = current_actor()
async with get_arbiter( async with get_arbiter(

1
tractor/_runtime.py
View File

@ -825,6 +825,7 @@ class Actor:
1, 1,
f'\n*** No stream open on `{self.uid[0]}` side! ***\n' f'\n*** No stream open on `{self.uid[0]}` side! ***\n'
) )
text = '\n'.join(lines) text = '\n'.join(lines)
if ctx._backpressure: if ctx._backpressure: