code: def _assert_pending_value(val: str, runtime_name, port):
      resp = req.get(f"http://localhost:{port}/")
      assert resp.status_code == 200
      assert (
          f'jina_number_of_pending_requests{{runtime_name="{runtime_name}"}} {val}'
          in str(resp.content)
      )
  
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 7 for calling a global function with example usage: _assert_pending_value(val, runtime_name, port) without return types