From 7d67f54ae88cc5b186a9abe26f3cdd8eb5603d64 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Tue, 11 May 2021 23:43:33 -0400
Subject: [PATCH] Proxy asyncio cancelleds as well

---
 tractor/to_asyncio.py | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/tractor/to_asyncio.py b/tractor/to_asyncio.py
index cd761c9..f678b55 100644
--- a/tractor/to_asyncio.py
+++ b/tractor/to_asyncio.py
@@ -101,7 +101,10 @@ def _run_asyncio_task(
         """Cancel the calling ``trio`` task on error.
         """
         nonlocal aio_err
-        aio_err = task.exception()
+        try:
+            aio_err = task.exception()
+        except asyncio.CancelledError as cerr:
+            aio_err = cerr
 
         if aio_err:
             log.exception(f"asyncio task errorred:\n{aio_err}")
@@ -233,17 +236,25 @@ async def run_task(
         #         raise aio_err
 
     # Do we need this?
-    except BaseException as err:
+    except Exception as err:
         # await tractor.breakpoint()
         aio_err = from_aio._err
+
+        # try:
         if aio_err is not None:
             # always raise from any captured asyncio error
             raise err from aio_err
         else:
             raise
+        # finally:
+        #     if not task.done():
+        #         task.cancel()
 
-    finally:
-        task.cancel()
+    except trio.Cancelled:
+        if not task.done():
+            task.cancel()
+
+        raise
 
 
 # async def stream_from_task