Fix an `aio_err` ref bug
parent
dfaae2238d
commit
986ada2ce9
|
@ -348,7 +348,6 @@ def _run_asyncio_task(
|
||||||
trio_task: trio.Task = trio.lowlevel.current_task()
|
trio_task: trio.Task = trio.lowlevel.current_task()
|
||||||
trio_cs = trio.CancelScope()
|
trio_cs = trio.CancelScope()
|
||||||
aio_task_complete = trio.Event()
|
aio_task_complete = trio.Event()
|
||||||
aio_err: BaseException|None = None
|
|
||||||
|
|
||||||
chan = LinkedTaskChannel(
|
chan = LinkedTaskChannel(
|
||||||
_to_aio=aio_q, # asyncio.Queue
|
_to_aio=aio_q, # asyncio.Queue
|
||||||
|
@ -392,7 +391,7 @@ def _run_asyncio_task(
|
||||||
if (
|
if (
|
||||||
result != orig
|
result != orig
|
||||||
and
|
and
|
||||||
aio_err is None
|
chan._aio_err is None
|
||||||
and
|
and
|
||||||
|
|
||||||
# in the `open_channel_from()` case we don't
|
# in the `open_channel_from()` case we don't
|
||||||
|
|
Loading…
Reference in New Issue