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

Offer `unpack_error(hid_tb: bool)` for `pdbp` REPL config

modden_spawn_from_client_req
Tyler Goodlet 2024-02-14 16:13:32 -05:00
parent df641d9d31
commit 286e75d342
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tractor/_exceptions.py
View File

@ -185,7 +185,8 @@ def unpack_error(
msg: dict[str, Any], msg: dict[str, Any],
chan=None, chan=None,
err_type=RemoteActorError err_type=RemoteActorError,
hide_tb: bool = True,
) -> None | Exception: ) -> None | Exception:
''' '''
@ -196,7 +197,7 @@ def unpack_error(
which is the responsibilitiy of the caller. which is the responsibilitiy of the caller.
''' '''
__tracebackhide__: bool = True __tracebackhide__: bool = hide_tb
error_dict: dict[str, dict] | None error_dict: dict[str, dict] | None
if ( if (
@ -309,6 +310,11 @@ def _raise_from_no_key_in_msg(
# value out of the underlying feed mem chan! # value out of the underlying feed mem chan!
stream._eoc: bool = True stream._eoc: bool = True
# TODO: if the a local task is already blocking on
# a `Context.result()` and thus a `.receive()` on the
# rx-chan, we close the chan and set state ensuring that
# an eoc is raised!
# # when the send is closed we assume the stream has # # when the send is closed we assume the stream has
# # terminated and signal this local iterator to stop # # terminated and signal this local iterator to stop
# await stream.aclose() # await stream.aclose()
@ -317,8 +323,8 @@ def _raise_from_no_key_in_msg(
# raise a ``StopAsyncIteration`` **and** in our catch # raise a ``StopAsyncIteration`` **and** in our catch
# block below it will trigger ``.aclose()``. # block below it will trigger ``.aclose()``.
raise trio.EndOfChannel( raise trio.EndOfChannel(
'Context[{cid}] stream ended due to msg:\n' f'Context stream ended due to msg:\n'
f'{pformat(msg)}' f'{pformat(msg)}'
) from src_err ) from src_err