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

to_asyncio: mask error logging, not sure it adds that much

dereg_on_oserror
Tyler Goodlet 2023-09-26 10:32:01 -04:00
parent 3dc57e384e
commit 3a31c9d338
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tractor/to_asyncio.py
View File

@ -216,7 +216,7 @@ def _run_asyncio_task(
try: try:
result = await coro result = await coro
except BaseException as aio_err: except BaseException as aio_err:
log.exception('asyncio task errored') # log.exception('asyncio task errored:')
chan._aio_err = aio_err chan._aio_err = aio_err
raise raise
@ -300,7 +300,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__)
log.error('infected task errorred') # log.error('infected task errorred')
# 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
@ -356,7 +356,7 @@ async def translate_aio_errors(
# relay cancel through to called ``asyncio`` task # relay cancel through to called ``asyncio`` task
assert chan._aio_task assert chan._aio_task
chan._aio_task.cancel( chan._aio_task.cancel(
msg=f'the `trio` caller task was cancelled: {trio_task.name}' msg=f'`trio`-side caller task cancelled: {trio_task.name}'
) )
raise raise
@ -366,7 +366,7 @@ async def translate_aio_errors(
trio.ClosedResourceError, trio.ClosedResourceError,
# trio.BrokenResourceError, # trio.BrokenResourceError,
): ):
aio_err = chan._aio_err aio_err: BaseException = chan._aio_err
if ( if (
task.cancelled() and task.cancelled() and
type(aio_err) is CancelledError type(aio_err) is CancelledError