diff --git a/examples/advanced_faults/ipc_failure_during_stream.py b/examples/advanced_faults/ipc_failure_during_stream.py index f3a709e0..c88e0dfe 100644 --- a/examples/advanced_faults/ipc_failure_during_stream.py +++ b/examples/advanced_faults/ipc_failure_during_stream.py @@ -16,6 +16,7 @@ from tractor import ( ContextCancelled, MsgStream, _testing, + trionics, ) import trio import pytest @@ -62,9 +63,8 @@ async def recv_and_spawn_net_killers( await ctx.started() async with ( ctx.open_stream() as stream, - trio.open_nursery( - strict_exception_groups=False, - ) as tn, + trionics.collapse_eg(), + trio.open_nursery() as tn, ): async for i in stream: print(f'child echoing {i}') diff --git a/examples/quick_cluster.py b/examples/quick_cluster.py index 2378a3cf..3fa4ca2a 100644 --- a/examples/quick_cluster.py +++ b/examples/quick_cluster.py @@ -23,9 +23,8 @@ async def main(): modules=[__name__] ) as portal_map, - trio.open_nursery( - strict_exception_groups=False, - ) as tn, + tractor.trionics.collapse_eg(), + trio.open_nursery() as tn, ): for (name, portal) in portal_map.items():