forked from goodboy/tractor
Make stream draining status logs `.debug()` level
parent
08a6a51cb8
commit
28fefe4ffe
|
@ -326,7 +326,7 @@ async def open_root_actor(
|
||||||
not entered
|
not entered
|
||||||
and not is_multi_cancelled(err)
|
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
|
# ALWAYS re-raise any error bubbled up from the
|
||||||
# runtime!
|
# runtime!
|
||||||
|
|
|
@ -265,7 +265,7 @@ class MsgStream(trio.abc.Channel):
|
||||||
try:
|
try:
|
||||||
maybe_final_msg = self.receive_nowait()
|
maybe_final_msg = self.receive_nowait()
|
||||||
if maybe_final_msg:
|
if maybe_final_msg:
|
||||||
log.cancel(
|
log.debug(
|
||||||
'Drained un-processed stream msg:\n'
|
'Drained un-processed stream msg:\n'
|
||||||
f'{pformat(maybe_final_msg)}'
|
f'{pformat(maybe_final_msg)}'
|
||||||
)
|
)
|
||||||
|
|
Loading…
Reference in New Issue