From d5eec6eb6c703b0b064c9ba71ebabce8bb1f9858 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Wed, 19 Mar 2025 15:59:56 -0400 Subject: [PATCH] Re-revert back to `.devx` subpkg after rebase.. --- tractor/_context.py | 6 +++--- tractor/_rpc.py | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/tractor/_context.py b/tractor/_context.py index 0be54860..a2860f3d 100644 --- a/tractor/_context.py +++ b/tractor/_context.py @@ -313,7 +313,7 @@ async def _drain_to_final_msg( log.critical('SHOULD NEVER GET HERE!?') assert msg is ctx._cancel_msg assert error.msgdata == ctx._remote_error.msgdata - from ._debug import pause + from .devx._debug import pause await pause() ctx._maybe_cancel_and_set_remote_error(error) ctx._maybe_raise_remote_err(error) @@ -2202,7 +2202,7 @@ async def open_context_from_portal( # pass # TODO: factor ^ into below for non-root cases? # - from ._debug import maybe_wait_for_debugger + from .devx._debug import maybe_wait_for_debugger was_acquired: bool = await maybe_wait_for_debugger( # header_msg=( # 'Delaying `ctx.cancel()` until debug lock ' @@ -2313,7 +2313,7 @@ async def open_context_from_portal( # where the root is waiting on the lock to clear but the # child has already cleared it and clobbered IPC. if debug_mode(): - from ._debug import maybe_wait_for_debugger + from .devx._debug import maybe_wait_for_debugger await maybe_wait_for_debugger() # though it should be impossible for any tasks diff --git a/tractor/_rpc.py b/tractor/_rpc.py index 47548106..89c97381 100644 --- a/tractor/_rpc.py +++ b/tractor/_rpc.py @@ -55,7 +55,7 @@ from ._exceptions import ( unpack_error, TransportClosed, ) -from . import _debug +from .devx import _debug from . import _state from .log import get_logger