From 38111e8d538831742360878dee9c345e0ac8d1d7 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sun, 7 Apr 2024 16:35:00 -0400 Subject: [PATCH] Detail out EoC-by-self log msg --- tractor/_streaming.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/tractor/_streaming.py b/tractor/_streaming.py index 941cfe8..dc30ac6 100644 --- a/tractor/_streaming.py +++ b/tractor/_streaming.py @@ -46,7 +46,6 @@ from .trionics import ( from tractor.msg import ( Stop, Yield, - Error, ) if TYPE_CHECKING: @@ -391,11 +390,11 @@ class MsgStream(trio.abc.Channel): if not self._eoc: log.cancel( - 'Stream closed before it received an EoC?\n' + '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._ctx.side}\n' + f'Context stream closed by self({self._ctx.side})\n' f'|_{self}\n' ) # ?XXX WAIT, why do we not close the local mem chan `._rx_chan` XXX?