def METHOD_NAME():
    """Initialize ray runtime if not already initialized. Will force the existence of a cluster already being spinned up"""
    try_import_ray()
    import ray
    if not ray.is_initialized():
        ray.init(
            address="auto",  # Force ray to connect to an existing cluster. There should be one. Otherwise, something went wrong
            log_to_driver=False,
            logging_level=logging.ERROR,
        )