code: def test_client_data_get(call_ray_start):
      """PySpark import changes NamedTuple pickling behavior, leading
      to inconpatibilities with the Ray client and Ray Data. This test
      makes sure that our fix in the ClientPickler works."""
      address = call_ray_start
      ip = address.split(":")[0]
  
      ray.util.connect(f"{ip}:10002")
  
      ray_pipeline = ray.data.from_items(list(range(1_000)))
      ray.get(ray_pipeline.to_numpy_refs()[0])
  
label_desc: Use image node_id 1 for calling a global function with example usage: test_client_data_get(call_ray_start) without return types