code: def run_one_wrk_trial(
      trial_length: str,
      num_connections: int,
      http_host: str,
      http_port: str,
      endpoint: str = "",
  ) -> None:
      proc = subprocess.Popen(
          [
              "wrk",
              "-c",
              str(num_connections),
              "-t",
              str(NUM_CPU_PER_NODE),
              "-d",
              trial_length,
              "--latency",
              f"http://{http_host}:{http_port}/{endpoint}",
          ],
          stdout=PIPE,
          stderr=PIPE,
      )
      proc.wait()
      out, err = proc.communicate()
  
      if err.decode() != "":
          logger.error(err.decode())
  
      return out.decode()
  
file_path: ray/release/serve_tests/workloads/serve_test_utils.py
imports: import json
  import logging
  import os
  import random
  import ray
  import re
  import subprocess
  from collections import defaultdict
  from serve_test_cluster_utils import NUM_CPU_PER_NODE
  from subprocess import PIPE
  from typing import Dict, List, Union
label_desc: Use image node_id 6 for calling a global function with example usage: run_one_wrk_trial(trial_length, num_connections, http_host, http_port, endpoint) and returns: out