From b69412a903eae1bc0ddc8c9a24d6338d7181aeba Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Wed, 24 Nov 2021 20:08:06 -0500
Subject: [PATCH] Drop cancel scope from linked task channel

---
 tractor/to_asyncio.py | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)

diff --git a/tractor/to_asyncio.py b/tractor/to_asyncio.py
index b6ec90e..0e85908 100644
--- a/tractor/to_asyncio.py
+++ b/tractor/to_asyncio.py
@@ -167,7 +167,6 @@ async def translate_aio_errors(
 
     from_aio: trio.MemoryReceiveChannel,
     task: asyncio.Task,
-    trio_cs: trio.CancelScope,
 
 ) -> None:
     '''
@@ -242,7 +241,7 @@ async def run_task(
     )
     with from_aio:
         # try:
-        async with translate_aio_errors(from_aio, task, cs):
+        async with translate_aio_errors(from_aio, task):
             # return single value that is the output from the
             # ``asyncio`` function-as-task. Expect the mem chan api to
             # do the job of handling cross-framework cancellations
@@ -263,7 +262,6 @@ class LinkedTaskChannel(trio.abc.Channel):
     _to_aio: asyncio.Queue
     _from_aio: trio.MemoryReceiveChannel
     _aio_task_complete: trio.Event
-    _trio_cs: trio.CancelScope
 
     async def aclose(self) -> None:
         self._from_aio.close()
@@ -272,7 +270,6 @@ class LinkedTaskChannel(trio.abc.Channel):
         async with translate_aio_errors(
             self._from_aio,
             self._aio_task,
-            self._trio_cs,
         ):
             return await self._from_aio.receive()
 
@@ -312,10 +309,10 @@ async def open_channel_from(
     )
     chan = LinkedTaskChannel(
         task, aio_q, from_aio,
-        aio_task_complete, cs
+        aio_task_complete
     )
     async with from_aio:
-        async with translate_aio_errors(from_aio, task, cs):
+        async with translate_aio_errors(from_aio, task):
             # sync to a "started()"-like first delivered value from the
             # ``asyncio`` task.
             first = await from_aio.receive()