From 0a240187c675c69043056c71d49a210e611bbe48 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Mon, 19 Nov 2018 16:52:55 -0500 Subject: [PATCH] Log the exception when unable to ship back rpc errors --- tractor/_actor.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/tractor/_actor.py b/tractor/_actor.py index ab3e434..1e7d173 100644 --- a/tractor/_actor.py +++ b/tractor/_actor.py @@ -125,8 +125,11 @@ async def _invoke( log.exception("Actor errored:") err_msg = pack_error(err) err_msg['cid'] = cid - await chan.send(err_msg) - + try: + await chan.send(err_msg) + except trio.ClosedResourceError: + log.exception( + f"Failed to ship error to caller @ {chan.uid}") if cs is None: # error is from above code not from rpc invocation task_status.started(err)