code: def _create_gateway(
      port, port_monitoring, graph, pod_addr, protocol, retries=-1
  ):
      # create a single worker runtime
      # create a single gateway runtime
      p = multiprocessing.Process(
          target=_create_gateway_runtime,
          args=(
              graph,
              pod_addr,
              port,
              port_monitoring,
              protocol,
              retries,
          ),
          daemon=True,
      )
      p.start()
      time.sleep(0.1)
      return p
  
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 4 for calling a global function with example usage: _create_gateway(port, port_monitoring, graph, pod_addr, protocol, retries) and returns: p