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

Few more log msg tweaks in runtime

modden_spawn_from_client_req
Tyler Goodlet 2024-02-22 15:06:39 -05:00
parent 930d498841
commit de1843dc84
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tractor/_runtime.py
View File

@ -973,11 +973,6 @@ class Actor:
# Attempt to wait for the far end to close the channel # Attempt to wait for the far end to close the channel
# and bail after timeout (2-generals on closure). # and bail after timeout (2-generals on closure).
assert chan.msgstream assert chan.msgstream
log.warning(
f'Draining lingering msgs from stream {chan.msgstream}'
)
async for msg in chan.msgstream.drain(): async for msg in chan.msgstream.drain():
# try to deliver any lingering msgs # try to deliver any lingering msgs
# before we destroy the channel. # before we destroy the channel.
@ -987,8 +982,11 @@ class Actor:
# delivered the local calling task. # delivered the local calling task.
# TODO: factor this into a helper? # TODO: factor this into a helper?
log.warning( log.warning(
'Draining msg from disconnected\n' 'Draining msg from disconnected peer\n'
f'peer: {chan.uid}]\n\n' f'{chan.uid}\n'
f'|_{chan}\n'
f' |_{chan.msgstream}\n\n'
f'{pformat(msg)}\n' f'{pformat(msg)}\n'
) )
cid = msg.get('cid') cid = msg.get('cid')
@ -1674,8 +1672,7 @@ class Actor:
if not tasks: if not tasks:
log.warning( log.warning(
'Actor has no cancellable RPC tasks?\n' 'Actor has no cancellable RPC tasks?\n'
f'<= cancel requester: {req_uid}\n' f'<= canceller: {req_uid}\n'
f'=> {self}\n\n'
) )
return return