code: def __init__(self, cluster_manager: ClusterManager):
      import anyscale
  
      super(JobFileManager, self).__init__(
          cluster_manager=cluster_manager
      )
  
      self.sdk = self.cluster_manager.sdk
      self.s3_client = boto3.client(S3_CLOUD_STORAGE)
      self.cloud_storage_provider = os.environ.get(
          "ANYSCALE_CLOUD_STORAGE_PROVIDER", S3_CLOUD_STORAGE
      )
      if self.cloud_storage_provider == S3_CLOUD_STORAGE:
          self.bucket = str(RELEASE_AWS_BUCKET)
      elif self.cloud_storage_provider == GS_CLOUD_STORAGE:
          self.bucket = GS_BUCKET
          self.gs_client = storage.Client()
      else:
          raise RuntimeError(
              f"Non supported anyscale service provider: "
              f"{self.cloud_storage_provider}"
          )
      self.job_manager = JobManager(cluster_manager)
      # Backward compatible
      if "ANYSCALE_RAY_DIR" in anyscale.__dict__:
          sys.path.insert(0, f"{anyscale.ANYSCALE_RAY_DIR}/bin")
  
imports: import os
  import shutil
  import sys
  import tempfile
  from typing import Optional
  import boto3
  from google.cloud import storage
  from ray_release.aws import RELEASE_AWS_BUCKET
  from ray_release.cluster_manager.cluster_manager import ClusterManager
  from ray_release.exception import FileDownloadError, FileUploadError
  from ray_release.file_manager.file_manager import FileManager
  from ray_release.job_manager import JobManager
  from ray_release.logger import logger
  from ray_release.util import exponential_backoff_retry, generate_tmp_cloud_storage_path, S3_CLOUD_STORAGE, GS_CLOUD_STORAGE, GS_BUCKET
label_desc: Use image node_id 1 to create a new JobFileManager object from inherited base classes: FileManager with example: obj = JobFileManager(cluster_manager)