code: def test_disable_prefetch_slow_client_fast_executor(
      protocol, inputs, use_stream
  ):
      if use_stream and protocol != "grpc":
          return
      print(
          f"\n\nRunning disable prefetch, slow client, fast Executor test for \n"
          f"protocol: {protocol}, input: {inputs.__name__}"
      )
      final_da = DocumentArray()
      with Flow(protocol=protocol, prefetch=0).add(
          uses=FastExecutor
      ) as f:
          f.post(
              on="/",
              inputs=inputs,
              request_size=1,
              on_done=lambda response: on_done(response, final_da),
              stream=use_stream,
          )
  
      assert len(final_da) == INPUT_LEN
      # Since the input_gen is slow, order will always be gen -> exec -> on_done for every request
      assert (
          final_da["id-0"].tags["input_gen"]
          < final_da["id-0"].tags["executor"]
      )
      assert (
          final_da["id-0"].tags["executor"]
          < final_da["id-0"].tags["on_done"]
      )
      assert (
          final_da["id-0"].tags["on_done"]
          < final_da["id-1"].tags["input_gen"]
      )
      assert (
          final_da["id-1"].tags["input_gen"]
          < final_da["id-1"].tags["executor"]
      )
      assert (
          final_da["id-1"].tags["executor"]
          < final_da["id-1"].tags["on_done"]
      )
      assert (
          final_da["id-1"].tags["on_done"]
          < final_da["id-2"].tags["input_gen"]
      )
      assert (
          final_da["id-2"].tags["input_gen"]
          < final_da["id-2"].tags["executor"]
      )
      assert (
          final_da["id-2"].tags["executor"]
          < final_da["id-2"].tags["on_done"]
      )
      assert (
          final_da["id-2"].tags["on_done"]
          < final_da["id-3"].tags["input_gen"]
      )
      assert (
          final_da["id-3"].tags["input_gen"]
          < final_da["id-3"].tags["executor"]
      )
      assert (
          final_da["id-3"].tags["executor"]
          < final_da["id-3"].tags["on_done"]
      )
  
imports: import asyncio
  import os
  import time
  from datetime import datetime
  from functools import partial
  from multiprocessing import Process, current_process
  from typing import List
  import pytest
  from jina import Client, Document, DocumentArray, Executor, Flow, requests
label_desc: Use image node_id 6 for calling a global function with example usage: test_disable_prefetch_slow_client_fast_executor(protocol, inputs, use_stream) without return types