async def METHOD_NAME():
    with instance_for_test() as instance:
        async with Scheduler() as scheduler:
            async with Worker(scheduler.address) as _:
                result = await asyncio.get_event_loop().run_in_executor(
                    None, _execute, scheduler.address, instance
                )
                assert result.success
                assert result.output_for_node("simple") == 1