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

Update our debugging example to wait on results

debug_tests
Tyler Goodlet 2020-09-28 13:13:53 -04:00
parent 5dd2d35fc5
commit d7a472c7f2
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
debugging/mp_debug.py
View File

@ -9,7 +9,7 @@ async def bubble():
await tractor.breakpoint() await tractor.breakpoint()
async def bail(): async def name_error():
getattr(doggy) getattr(doggy)
@ -19,13 +19,21 @@ async def main():
async with tractor.open_nursery() as n: async with tractor.open_nursery() as n:
portal1 = await n.run_in_actor('bubble', bubble) portal1 = await n.run_in_actor('bubble', bubble)
portal = await n.run_in_actor('bail', bail) portal = await n.run_in_actor('name_error', name_error)
# await portal.result() await portal1.result()
# await portal1.result() await portal.result()
# The ``async with`` will unblock here since the 'some_linguist' # The ``async with`` will unblock here since the 'some_linguist'
# actor has completed its main task ``cellar_door``. # actor has completed its main task ``cellar_door``.
# TODO:
# - recurrent entry from single actor
# - recurrent entry to breakpoint() from single actor *after* and an
# error
# - root error alongside child errors
# - recurrent root errors
if __name__ == '__main__': if __name__ == '__main__':
tractor.run(main, loglevel='error', debug_mode=True) tractor.run(main, loglevel='info', debug_mode=True)