code: def run_storage_cp(source: str, target: str):
      if not source or not target:
          return False
  
      if not Path(source).exists():
          logger.warning(
              f"Couldn't upload to cloud storage: '{source}' does not exist."
          )
          return False
  
      storage_service = urlparse(target).scheme
      cp_cmd_args = []
      if storage_service == "s3":
          cp_cmd_args = [
              "aws",
              "s3",
              "cp",
              source,
              target,
              "--acl",
              "bucket-owner-full-control",
          ]
      elif storage_service == "gs":
          cp_cmd_args = [
              "gcloud",
              "storage",
              "cp",
              source,
              target,
          ]
      else:
          raise Exception(
              f"Not supporting storage service: {storage_service}"
          )
  
      try:
          exponential_backoff_retry(
              lambda: subprocess.run(
                  cp_cmd_args,
                  timeout=AWS_CP_TIMEOUT,
                  check=True,
              ),
              subprocess.SubprocessError,
              initial_retry_delay_s=10,
              max_retries=3,
          )
          return True
      except subprocess.SubprocessError:
          logger.exception("Couldn't upload to cloud storage.")
          return False
  
file_path: ray/release/ray_release/command_runner/_anyscale_job_wrapper.py
imports: import argparse
  import time
  import os
  from pathlib import Path
  import subprocess
  import multiprocessing
  import json
  import sys
  import logging
  from urllib.parse import urlparse
  from typing import Optional, List, Tuple
label_desc: Use image node_id 3 for calling a global function with example usage: run_storage_cp(source, target) and returns: False, False, True, False