code: def test_transform_failure(shutdown_only):
      ray.init(num_cpus=2)
      ds = ray.data.from_items([0, 10], parallelism=2)
  
      def mapper(x):
          time.sleep(x)
          raise ValueError("oops")
          return x
  
      with pytest.raises(ray.exceptions.RayTaskError):
          ds.map(mapper).materialize()
  
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 4 for calling a global function with example usage: test_transform_failure(shutdown_only) and returns: x