forked from goodboy/tractor
Drop to a 2 polls for root debugging check
parent
a3cdba0577
commit
0488f5e57e
|
@ -350,7 +350,7 @@ async def _breakpoint(
|
||||||
|
|
||||||
async with ctx.open_stream() as stream:
|
async with ctx.open_stream() as stream:
|
||||||
|
|
||||||
log.error('opened stream')
|
log.debug('opened stream')
|
||||||
# unblock local caller
|
# unblock local caller
|
||||||
task_status.started()
|
task_status.started()
|
||||||
|
|
||||||
|
@ -564,11 +564,12 @@ async def maybe_wait_for_debugger() -> None:
|
||||||
if _global_actor_in_debug:
|
if _global_actor_in_debug:
|
||||||
sub_in_debug = tuple(_global_actor_in_debug)
|
sub_in_debug = tuple(_global_actor_in_debug)
|
||||||
|
|
||||||
for _ in range(2):
|
for _ in range(1):
|
||||||
with trio.CancelScope(shield=True):
|
with trio.CancelScope(shield=True):
|
||||||
|
|
||||||
log.warning(
|
log.pdb(
|
||||||
'Root polling for debug')
|
'Polling for debug lock'
|
||||||
|
)
|
||||||
await trio.sleep(0.01)
|
await trio.sleep(0.01)
|
||||||
|
|
||||||
debug_complete = _no_remote_has_tty
|
debug_complete = _no_remote_has_tty
|
||||||
|
|
Loading…
Reference in New Issue