forked from goodboy/tractor
1
0
Fork 0

Tweak a couple more log message fmts

runtime_to_msgspec
Tyler Goodlet 2024-04-15 15:20:00 -04:00
parent d4155396bf
commit 5dfff3f75a
2 changed files with 10 additions and 7 deletions

View File

@ -1902,7 +1902,7 @@ class Context:
try:
log.runtime(
f'Delivering msg from IPC ctx:\n'
f'Delivering msg from IPC ctx:\n\n'
f'<= {from_uid}\n'
f' |_ {nsf}()\n\n'

View File

@ -377,14 +377,17 @@ class MsgStream(trio.abc.Channel):
# await rx_chan.aclose()
if not self._eoc:
log.cancel(
'Stream closed by self before it received an EoC?\n'
'Setting eoc manually..\n..'
)
self._eoc: bool = trio.EndOfChannel(
f'Context stream closed by self({self._ctx.side})\n'
message: str = (
f'Context stream closed by {self._ctx.side!r}\n'
f'|_{self}\n'
)
log.cancel(
'Stream self-closed before receiving EoC\n\n'
+
message
)
self._eoc = trio.EndOfChannel(message)
# ?XXX WAIT, why do we not close the local mem chan `._rx_chan` XXX?
# => NO, DEFINITELY NOT! <=
# if we're a bi-dir ``MsgStream`` BECAUSE this same