code: def test_map_batches_actors_preserves_order(shutdown_only):
      class UDFClass:
          def __call__(self, x):
              return x
  
      ray.shutdown()
      ray.init(num_cpus=2)
      # Test that actor compute model preserves block order.
      ds = ray.data.range(10, parallelism=5)
      assert extract_values(
          "id", ds.map_batches(UDFClass, concurrency=1).take()
      ) == list(range(10))
  
imports: import itertools
  import math
  import os
  import signal
  import threading
  import time
  from typing import Iterator
  import numpy
  import pandas
  import pyarrow
  import pyarrow.parquet
  import pytest
  import ray
  from ray._private.test_utils import wait_for_condition
  from ray.data.block import BlockAccessor
  from ray.data.context import DataContext
  from ray.data.tests.conftest import *
  from ray.data.tests.util import column_udf, column_udf_class, extract_values
  from ray.tests.conftest import *
label_desc: Use image node_id 13 for calling a global function with example usage: test_map_batches_actors_preserves_order(shutdown_only) and returns: x