code: def parquet_file(ray_cluster_2cpu) -> str:
      """Write a multi-file parquet dataset to the cwd.
  
      Returns:
          The path to the parquet dataset.
      """
      # The data needs to be written to a multi-file parquet format, otherwise the issue doesn't repro. To do this, we
      # partitition a test dataframe with dask and then write to file.
      df = pd.DataFrame(
          {"col1": list(range(1000)), "col2": list(range(1000))}
      )
      df = dask.dataframe.from_pandas(df, chunksize=100)
  
      # Typically we would write test data to a temporary directory, but the issue this was set up to test only happens
      # when using relative filepaths.
      cwd = os.getcwd()
      filepath = os.path.join(cwd, "data.training.parquet")
      df.to_parquet(filepath, engine="pyarrow")
  
      yield filepath
  
      # Clean up the data
      shutil.rmtree(filepath)
  
file_path: ludwig/tests/ludwig/data/test_ray_data.py
imports: import os
  import shutil
  from unittest import mock
  import pandas
  import pytest
  from ludwig.data.dataset.ray import RayDatasetBatcher, read_remote_parquet
label_desc: Use image node_id 2 for calling a global function with example usage: parquet_file(ray_cluster_2cpu) without return types