code: def _assert_all_docs_processed(port, num_docs, endpoint):
      resp = send_request_sync(
          _create_test_data_message(num_docs, endpoint=endpoint),
          target=f"0.0.0.0:{port}",
          endpoint=endpoint,
      )
      docs = resp.data.docs
      assert docs.texts == ["long timeout" for _ in range(num_docs)]
  
imports: import asyncio
  import multiprocessing
  import multiprocessing
  import os
  import signal
  import time
  from collections import namedtuple
  import pytest
  from jina import Client, Document, DocumentArray, Executor, Flow, Deployment, dynamic_batching, requests
  from jina.clients.request import request_generator
  from jina.serve.networking.utils import send_request_sync
  from jina.serve.runtimes.servers import BaseServer
  from jina_cli.api import executor_native
  from jina.proto import jina_pb2
  from tests.helper import _generate_pod_args
label_desc: Use image node_id 9 for calling a global function with example usage: _assert_all_docs_processed(port, num_docs, endpoint) without return types