Always `.exception()` in `try_ship_error_to_remote()` on internal error

runtime_to_msgspec
Tyler Goodlet 2024-05-30 16:02:25 -04:00
parent d51c19fe3d
commit 1c00668d20
1 changed files with 6 additions and 1 deletions

View File

@ -326,7 +326,6 @@ async def _errors_relayed_via_ipc(
f'|_{ctx}'
)
# ALWAYS try to ship RPC errors back to parent/caller task
if is_rpc:
@ -817,6 +816,12 @@ async def try_ship_error_to_remote(
# TODO: use `.msg.preetty_struct` for this!
f'{msg}\n'
)
except BaseException:
log.exception(
'Errored while attempting error shipment?'
)
__tracebackhide__: bool = False
raise
async def process_messages(