tractor/examples/remote_error_propagation.py

import trio
import tractor


async def assert_err():
    assert 0


async def main():
    async with tractor.open_nursery() as an:
        real_actors = []
        for i in range(3):
            real_actors.append(await an.start_actor(
                f'actor_{i}',
                enable_modules=[__name__],
            ))

        # run one one-shot task actor that will fail immediately;
        # its error raises right here in the caller's task..
        await tractor.to_actor.run(assert_err, an=an)

    # ..as a ``RemoteActorError`` containing an ``AssertionError``
    # and all the other actors have been cancelled


if __name__ == '__main__':
    try:
        # also raises
        trio.run(main)
    except tractor.RemoteActorError:
        print("Look Maa that actor failed hard, hehhh!")