jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Drop manual stack construction, fix attr typo

aio_error_propagation^2
Tyler Goodlet 2022-07-14 20:43:17 -04:00
parent 38d03858d7
commit 0906559ed9
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tractor/to_asyncio.py
View File

@ -297,10 +297,7 @@ def _run_asyncio_task(
elif task_err is None: elif task_err is None:
assert aio_err assert aio_err
aio_err.with_traceback(aio_err.__traceback__) aio_err.with_traceback(aio_err.__traceback__)
msg = ''.join(traceback.format_exception(type(aio_err))) log.error(f'infected task errorred')
log.error(
f'infected task errorred:\n{msg}'
)
# XXX: alway cancel the scope on error # XXX: alway cancel the scope on error
# in case the trio task is blocking # in case the trio task is blocking
@ -391,7 +388,7 @@ async def translate_aio_errors(
or chan._trio_exited or chan._trio_exited
): ):
log.runtime( log.runtime(
f'Cancelling `asyncio`-task: {chan._aio_taskget_name()}' f'Cancelling `asyncio`-task: {chan._aio_task.get_name()}'
) )
# assert not aio_err, 'WTF how did asyncio do this?!' # assert not aio_err, 'WTF how did asyncio do this?!'
task.cancel() task.cancel()