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

Few more log msg tweaks in runtime

remotes/1757153874605917753/main
Tyler Goodlet 2024-02-22 15:06:39 -05:00
parent 4d0df1bb4a
commit a388d3185b
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

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