code: def run_test():
      failed_workloads = []
      for workload in WORKLOAD_SCRIPTS:
          # Run the python script.
          logger.info(f"Running workload {workload}:")
          try:
              subprocess.check_call(["python", workload])
          except subprocess.CalledProcessError as e:
              failed_workloads.append((workload, e))
  
      if failed_workloads:
          for workload, e in failed_workloads:
              logger.error(f"Workload {workload} failed with {e}")
      else:
          logger.info("All workloads passed!")
  
file_path: ray/release/autoscaling_tests/run.py
imports: import subprocess
  import click
  import json
  import os
  import time
  from logger import logger
label_desc: Use image node_id 2 for calling a global function with example usage: run_test() without return types