Log the exception when unable to ship back rpc errors

2018-11-19 16:52:55 -05:00 · 2018-11-19 16:52:55 -05:00 · 0a240187c6
parent 7a2b7d9d14
commit 0a240187c6
1 changed files with 5 additions and 2 deletions
--- 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)