From 28fefe4ffecc4bddcfb9ffc01eca1641d04f52c9 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Fri, 1 Mar 2024 19:27:10 -0500 Subject: [PATCH] Make stream draining status logs `.debug()` level --- tractor/_root.py | 2 +- tractor/_streaming.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/tractor/_root.py b/tractor/_root.py index 32cc3d5..c3deac9 100644 --- a/tractor/_root.py +++ b/tractor/_root.py @@ -326,7 +326,7 @@ async def open_root_actor( not entered and not is_multi_cancelled(err) ): - logger.exception("Root actor crashed:") + logger.exception('Root actor crashed:\n') # ALWAYS re-raise any error bubbled up from the # runtime! diff --git a/tractor/_streaming.py b/tractor/_streaming.py index 64b5dd6..b2cfe48 100644 --- a/tractor/_streaming.py +++ b/tractor/_streaming.py @@ -265,7 +265,7 @@ class MsgStream(trio.abc.Channel): try: maybe_final_msg = self.receive_nowait() if maybe_final_msg: - log.cancel( + log.debug( 'Drained un-processed stream msg:\n' f'{pformat(maybe_final_msg)}' )