code: def _create_model(cls):
      return cls(
          text="Test output",
          floats=[float(f) for f in range(1, 100)],
          ints=list(range(1, 100)),
          ts=time.time(),
          reason="Success!",
      )
  
file_path: ray/python/ray/serve/_private/benchmarks/serialization/serialization_benchmark.py
imports: import asyncio
  import enum
  import pickle
  import time
  from typing import Any, Callable
  import click
  import msgpack
  from ray._private.serialization import SerializationContext
  from ray.cloudpickle import cloudpickle_fast
  from ray.serve._private.benchmarks.common import collect_profile_events, run_latency_benchmark
  from ray.serve._private.benchmarks.serialization.common import PayloadDataclass, PayloadPydantic
label_desc: Use image node_id 1 for calling a global function with example usage: _create_model(cls) and returns: cls