goodboy
/
tractor
1
0
Fork 2
Code Issues 3 Pull Requests 6 Packages Projects Releases Wiki Activity

Comment-tag pause points in `asycnio_bp.py` 

Thought i already did this but, obvi needed these to make the expect
matches pass in our test.
py313_support
Tyler Goodlet 2025-03-05 09:54:56 -05:00
parent 8537ff4cd6
commit c9234fbd9c
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
examples/debugging/asyncio_bp.py
View File

@ -25,7 +25,7 @@ async def bp_then_error(
) -> None: ) -> None:
# sync with ``trio``-side (caller) task # sync with `trio`-side (caller) task
to_trio.send_nowait('start') to_trio.send_nowait('start')
# NOTE: what happens here inside the hook needs some refinement.. # NOTE: what happens here inside the hook needs some refinement..
@ -33,8 +33,7 @@ async def bp_then_error(
# we set `Lock.local_task_in_debug = 'sync'`, we probably want # we set `Lock.local_task_in_debug = 'sync'`, we probably want
# some further, at least, meta-data about the task/actor in debug # some further, at least, meta-data about the task/actor in debug
# in terms of making it clear it's `asyncio` mucking about. # in terms of making it clear it's `asyncio` mucking about.
breakpoint() breakpoint() # asyncio-side
# short checkpoint / delay # short checkpoint / delay
await asyncio.sleep(0.5) # asyncio-side await asyncio.sleep(0.5) # asyncio-side
@ -58,7 +57,6 @@ async def trio_ctx(
# this will block until the ``asyncio`` task sends a "first" # this will block until the ``asyncio`` task sends a "first"
# message, see first line in above func. # message, see first line in above func.
async with ( async with (
to_asyncio.open_channel_from( to_asyncio.open_channel_from(
bp_then_error, bp_then_error,
# raise_after_bp=not bp_before_started, # raise_after_bp=not bp_before_started,
@ -69,7 +67,7 @@ async def trio_ctx(
assert first == 'start' assert first == 'start'
if bp_before_started: if bp_before_started:
await tractor.pause() await tractor.pause() # trio-side
await ctx.started(first) # trio-side await ctx.started(first) # trio-side
@ -111,7 +109,7 @@ async def main(
# pause in parent to ensure no cross-actor # pause in parent to ensure no cross-actor
# locking problems exist! # locking problems exist!
await tractor.pause() await tractor.pause() # trio-root
if cancel_from_root: if cancel_from_root:
await ctx.cancel() await ctx.cancel()