Our code for recovering after a "foreign await" needs to be reworked #552
Description
Just doing some testing to see if I can use dask.distributed with trio & trio_asyncio but have fallen at the first hurdle and hit a TrioInternalError:
import asyncio
import trio
import trio_asyncio
from dask.distributed import Client
async def f():
async with trio_asyncio.open_loop() as loop:
client = await Client(asynchronous=True)
future = client.submit(lambda x: x + 1, 10)
return await future
trio.run(f)---------------------------------------------------------------------------
AssertionError Traceback (most recent call last)
C:\Miniconda3\lib\site-packages\trio\_core\_run.py in run(async_fn, clock, instruments, restrict_keyboard_interrupt_to_checkpoints, *args)
1228 # is just to get rid of this extra indentation.
-> 1229 result = run_impl(runner, async_fn, args)
1230 except TrioInternalError:
C:\Miniconda3\lib\site-packages\trio\_core\_run.py in run_impl(runner, async_fn, args)
1356 # other exceptions as __context__ in unwanted ways.
-> 1357 runner.task_exited(task, final_result)
1358 else:
C:\Miniconda3\lib\site-packages\trio\_core\_run.py in task_exited(self, task, result)
854 # the init task should be the last task to exit
--> 855 assert not self.tasks
856 else:
AssertionError:
The above exception was the direct cause of the following exception:
TrioInternalError Traceback (most recent call last)
<ipython-input-41-03c750b89f65> in <module>()
----> 1 trio.run(f)
C:\Miniconda3\lib\site-packages\trio\_core\_run.py in run(async_fn, clock, instruments, restrict_keyboard_interrupt_to_checkpoints, *args)
1233 raise TrioInternalError(
1234 "internal error in trio - please file a bug!"
-> 1235 ) from exc
1236 finally:
1237 GLOBAL_RUN_CONTEXT.__dict__.clear()
TrioInternalError: internal error in trio - please file a bug!Happy to move this to the trio_asyncio repo if that's a more appropriate place...