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

More bitty (runtime) logging tweaks

runtime_to_msgspec
Tyler Goodlet 2024-04-26 13:13:04 -04:00
parent a5a0e6854b
commit 61db040702
2 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tractor/_portal.py
View File

@ -254,11 +254,11 @@ class Portal:
return False return False
reminfo: str = ( reminfo: str = (
f'`Portal.cancel_actor()` => {self.channel.uid}\n' f'Portal.cancel_actor() => {self.channel.uid}\n'
f'|_{chan}\n' f'|_{chan}\n'
) )
log.cancel( log.cancel(
f'Sending runtime `.cancel()` request to peer\n\n' f'Requesting runtime cancel for peer\n\n'
f'{reminfo}' f'{reminfo}'
) )

8
tractor/_streaming.py
View File

@ -364,14 +364,10 @@ class MsgStream(trio.abc.Channel):
if not self._eoc: if not self._eoc:
message: str = ( message: str = (
f'Context stream closed by {self._ctx.side!r}\n' f'Stream self-closed by {self._ctx.side!r}-side before EoC\n'
f'|_{self}\n' f'|_{self}\n'
) )
log.cancel( log.cancel(message)
'Stream self-closed before receiving EoC\n\n'
+
message
)
self._eoc = trio.EndOfChannel(message) self._eoc = trio.EndOfChannel(message)
# ?XXX WAIT, why do we not close the local mem chan `._rx_chan` XXX? # ?XXX WAIT, why do we not close the local mem chan `._rx_chan` XXX?