hunk.code_window: from ray_release.job_manager.anyscale_job_manager import AnyscaleJobManager
   def test_get_ray_error_logs():
       with tempfile.TemporaryDirectory() as tmpdir:
           with open(os.path.join(tmpdir, "log01"), "w") as f:
  
hunk.labels: keep keep add keep keep keep
hunk.after_edit: class FakeJobResult:
       def __init__(self, _id: str):
           self.id = _id
  
hunk.file_path: release/ray_release/tests/test_anyscale_job_manager.py
hunk.type: add
file: cloud_id: {{env["ANYSCALE_CLOUD_ID"]}}
  region: us-west-2
  
  aws:
      BlockDeviceMappings:
          - DeviceName: /dev/sda1
            Ebs:
              DeleteOnTermination: true
              VolumeSize: 500
  
  head_node_type:
      name: head_node
      instance_type: m5.8xlarge
      resources:
        cpu: 0
  
  worker_node_types:
     - name: worker_node
       instance_type: m5.4xlarge
       min_workers: 210
       max_workers: 210
       use_spot: false
       resources:
        cpu: 32
  