code: def test_multiplexed_detect(manage_ray_with_telemetry):
      """Check that multiplexed api is detected by telemetry."""
  
      subprocess.check_output(["ray", "start", "--head"])
      wait_for_condition(check_ray_started, timeout=5)
  
      @serve.deployment
      class Model:
          @serve.multiplexed(max_num_models_per_replica=1)
          async def get_model(self, tag):
              return tag
  
          async def __call__(self, request):
              tag = serve.get_multiplexed_model_id()
              await self.get_model(tag)
              return tag
  
      serve.run(Model.bind(), name="app", route_prefix="/app")
  
      storage_handle = start_telemetry_app()
      wait_for_condition(
          lambda: ray.get(storage_handle.get_reports_received.remote())
          > 0,
          timeout=5,
      )
      report = ray.get(storage_handle.get_report.remote())
      assert (
          ServeUsageTag.MULTIPLEXED_API_USED.get_value_from_report(
              report
          )
          is None
      )
  
      client = _get_global_client()
      wait_for_condition(
          lambda: client.get_serve_status("app").app_status.status
          == ApplicationStatus.RUNNING,
          timeout=15,
      )
  
      wait_for_condition(
          lambda: ray.get(storage_handle.get_reports_received.remote())
          > 0,
          timeout=5,
      )
  
      headers = {SERVE_MULTIPLEXED_MODEL_ID: "1"}
      resp = requests.get("http://localhost:8000/app", headers=headers)
      assert resp.status_code == 200
  
      wait_for_condition(
          lambda: int(
              ServeUsageTag.MULTIPLEXED_API_USED.get_value_from_report(
                  ray.get(storage_handle.get_report.remote())
              )
          )
          == 1,
          timeout=5,
      )
  
imports: import subprocess
  import sys
  import time
  import pytest
  import requests
  import yaml
  from fastapi import FastAPI
  import ray
  from ray import serve
  from ray._private.test_utils import wait_for_condition
  from ray._private.usage.usage_lib import get_extra_usage_tags_to_report
  from ray.serve._private.common import ApplicationStatus
  from ray.serve._private.constants import SERVE_MULTIPLEXED_MODEL_ID
  from ray.serve._private.test_utils import TELEMETRY_ROUTE_PREFIX, TelemetryStorage, check_ray_started, receiver_app, start_telemetry_app
  from ray.serve._private.usage import ServeUsageTag
  from ray.serve.context import _get_global_client
  from ray.serve.schema import ServeDeploySchema
label_desc: Use image node_id 6 for calling a global function with example usage: test_multiplexed_detect(manage_ray_with_telemetry) and returns: tag, tag