async def METHOD_NAME():
    mo.setup_cluster(address_to_resources=TEST_ADDRESS_TO_RESOURCES)
    main_pool_handles = []  # Hold actor_handle to avoid actor being freed.
    for index, bundle_spec in enumerate(TEST_PLACEMENT_GROUP_BUNDLES):
        address = process_placement_to_address(TEST_PLACEMENT_GROUP_NAME, index, 0)
        actor_handle = await mo.create_actor_pool(address, bundle_spec["CPU"])
        main_pool_handles.append(actor_handle)
    yield
    RayActorDriver.stop_cluster()
    RayServer.clear()