code: def test_wide_fanout_deployment_graph(
      fanout_degree, init_delay_secs=0, compute_delay_secs=0
  ):
      r"""
      Test that focuses on wide fanout of deployment graph
          -> Node_1
          /          \
      INPUT --> Node_2  --> combine -> OUTPUT
          \    ...   /
          -> Node_10
  
      1) Intermediate blob size can be large / small
      2) Compute time each node can be long / short
      3) Init time can be long / short
      """
      nodes = [
          Node.bind(i, init_delay_secs=init_delay_secs)
          for i in range(0, fanout_degree)
      ]
  
      return Combine.bind(nodes)
  
file_path: ray/release/serve_tests/workloads/deployment_graph_wide_ensemble.py
imports: import time
  import asyncio
  import click
  from typing import Optional
  from ray import serve
  from serve_test_cluster_utils import setup_local_single_node_cluster, setup_anyscale_cluster
  from serve_test_utils import save_test_results
  from benchmark_utils import benchmark_throughput_tps, benchmark_latency_ms
label_desc: Use image node_id 1 for calling a global function with example usage: test_wide_fanout_deployment_graph(fanout_degree, init_delay_secs, compute_delay_secs) and returns: Combine