code: def _check_all_replicas_connected(
      num_replicas, gateway_port, protocol
  ):
      """check if all replicas are connected"""
      exec_ids = set()
      exec_id_list = []
      for i in range(num_replicas + 1):
          id_ = _send_request(gateway_port, protocol, request_size=2)[
              0
          ].text
          exec_ids.add(id_)
          exec_id_list.append(id_)
      print(exec_id_list)
      assert len(exec_ids) == num_replicas
  
imports: import multiprocessing
  import time
  import uuid
  import pytest
  from docarray import DocumentArray
  from jina import Client, Executor, requests
  from jina.parsers import set_gateway_parser
  from jina.serve.runtimes.asyncio import AsyncNewLoopRuntime
  from jina.serve.runtimes.servers import BaseServer
  from jina.serve.runtimes.worker.request_handling import WorkerRequestHandler
  from jina.serve.runtimes.gateway.request_handling import GatewayRequestHandler
  from tests.helper import _generate_pod_args
  from tests.integration.runtimes.test_runtimes import _create_gateway_runtime, _create_head_runtime
label_desc: Use image node_id 5 for calling a global function with example usage: _check_all_replicas_connected(num_replicas, gateway_port, protocol) without return types