code: def stop_model_ids_pusher_thread(multiplexer):
      multiplexer.metrics_pusher.stop_event.set()
      wait_for_condition(
          lambda: multiplexer.metrics_pusher.pusher_thread.is_alive()
          is False
      )
  
imports: import asyncio
  import os
  from typing import List
  import pytest
  import requests
  import ray
  from ray import serve
  from ray._private.test_utils import SignalActor, wait_for_condition
  from ray._private.utils import get_or_create_event_loop
  from ray.serve._private.constants import SERVE_MULTIPLEXED_MODEL_ID
  from ray.serve.context import _get_internal_replica_context
  from ray.serve.handle import RayServeHandle
  from ray.serve.multiplex import _ModelMultiplexWrapper
label_desc: Use image node_id 2 for calling a global function with example usage: stop_model_ids_pusher_thread(multiplexer) without return types