code: def _send_request(gateway_port, protocol, n_docs=2):
      """send request to gateway and see what happens"""
      from jina.clients import Client
  
      c = Client(host="localhost", port=gateway_port, protocol=protocol)
      return c.post(
          "/foo",
          inputs=[Document(text="hi") for _ in range(n_docs)],
          request_size=1,
          return_responses=True,
          continue_on_error=True,
      )
  
file_path: jina/tests/integration/monitoring/test_manual_flow.py
imports: import multiprocessing
  import time
  import pytest
  import requests
  from docarray import Document, DocumentArray
  from jina import Executor, Flow, requests
  from jina.parsers import set_gateway_parser
  from jina.serve.runtimes.asyncio import AsyncNewLoopRuntime
  from jina.serve.runtimes.worker.request_handling import WorkerRequestHandler
  from jina.serve.runtimes.gateway.request_handling import GatewayRequestHandler
  from jina.serve.runtimes.servers import BaseServer
  from tests.helper import _generate_pod_args
label_desc: Use image node_id 5 for calling a global function with example usage: _send_request(gateway_port, protocol, n_docs) and returns: c