From fc130d06b8d8535362adfcee61f485df387afbe7 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Tue, 9 Sep 2025 18:13:28 -0400 Subject: [PATCH] Check off REPL-ing todo add masked usage in `drain_to_final_msg()` --- tractor/msg/_ops.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/tractor/msg/_ops.py b/tractor/msg/_ops.py index 1dad63c8..aa215a81 100644 --- a/tractor/msg/_ops.py +++ b/tractor/msg/_ops.py @@ -613,10 +613,9 @@ async def drain_to_final_msg( # msg: dict = await ctx._rx_chan.receive() # if res_cs.cancelled_caught: # - # -[ ] make sure pause points work here for REPLing + # -[x] make sure pause points work here for REPLing # the runtime itself; i.e. ensure there's no hangs! - # |_from tractor.devx.debug import pause - # await pause() + # |_see masked code below in .cancel_called path # NOTE: we get here if the far end was # `ContextCancelled` in 2 cases: @@ -652,6 +651,10 @@ async def drain_to_final_msg( f'IPC ctx cancelled externally during result drain ?\n' f'{ctx}' ) + # XXX, for tracing `Cancelled`.. + # from tractor.devx.debug import pause + # await pause(shield=True) + # CASE 2: mask the local cancelled-error(s) # only when we are sure the remote error is # the source cause of this local task's