goodboy
/
tractor
1
0
Fork 2
Code Issues 5 Pull Requests 8 Packages Projects Releases Wiki Activity

Port `Actor._stream_handler()` to use `.has_outcome`, fix indent bug..

runtime_to_msgspec
Tyler Goodlet 2024-05-22 15:10:39 -04:00
parent 92ac95ce24
commit 50ed461996
1 changed files with 20 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
tractor/_runtime.py
View File

@ -694,21 +694,21 @@ class Actor:
proc: trio.Process proc: trio.Process
_, proc, _ = entry _, proc, _ = entry
if ( if (
(poll := getattr(proc, 'poll', None)) (poll := getattr(proc, 'poll', None))
and poll() is None and poll() is None
): ):
log.cancel( log.cancel(
'Root actor reports no-more-peers, BUT\n' 'Root actor reports no-more-peers, BUT\n'
'a DISCONNECTED child still has the debug ' 'a DISCONNECTED child still has the debug '
'lock!\n\n' 'lock!\n\n'
# f'root uid: {self.uid}\n' # f'root uid: {self.uid}\n'
f'last disconnected child uid: {uid}\n' f'last disconnected child uid: {uid}\n'
f'locking child uid: {pdb_user_uid}\n' f'locking child uid: {pdb_user_uid}\n'
) )
await _debug.maybe_wait_for_debugger( await _debug.maybe_wait_for_debugger(
child_in_debug=True child_in_debug=True
) )
# TODO: just bc a child's transport dropped # TODO: just bc a child's transport dropped
# doesn't mean it's not still using the pdb # doesn't mean it's not still using the pdb
@ -1142,7 +1142,6 @@ class Actor:
requester_type, requester_type,
req_chan, req_chan,
log_meth, log_meth,
) = ( ) = (
req_chan.uid, req_chan.uid,
'peer', 'peer',
@ -1175,7 +1174,11 @@ class Actor:
# with the root actor in this tree # with the root actor in this tree
debug_req = _debug.DebugStatus debug_req = _debug.DebugStatus
lock_req_ctx: Context = debug_req.req_ctx lock_req_ctx: Context = debug_req.req_ctx
if lock_req_ctx is not None: if (
lock_req_ctx
and
lock_req_ctx.has_outcome
):
msg += ( msg += (
'-> Cancelling active debugger request..\n' '-> Cancelling active debugger request..\n'
f'|_{_debug.Lock.repr()}\n\n' f'|_{_debug.Lock.repr()}\n\n'