code: def setup_kuberay_operator():
      """Set up KubeRay operator and Ray autoscaler RBAC."""
      switch_to_ray_parent_dir()
      logger.info(
          "Cloning KubeRay and setting up KubeRay configuration."
      )
      # For faster run-time when triggering the test locally, don't run the init
      # script if it has already been run.
      subprocess.check_call(
          [
              "bash",
              "-c",
              (
                  "ls ray/python/ray/autoscaler/kuberay/config ||"
                  " ./ray/python/ray/autoscaler/kuberay/init-config.sh"
              ),
          ]
      )
      logger.info("Creating KubeRay operator.")
      subprocess.check_call(
          [
              "kubectl",
              "create",
              "-k",
              "ray/python/ray/autoscaler/kuberay/config/default",
          ]
      )
  
imports: import atexit
  import contextlib
  import logging
  import pathlib
  import subprocess
  import tempfile
  import time
  from typing import Any, Dict, Generator, List, Optional
  import yaml
  import os
  import ray
  from ray.job_submission import JobStatus, JobSubmissionClient
label_desc: Use image node_id 2 for calling a global function with example usage: setup_kuberay_operator() without return types