code: def to_distributed(df):
      return ray.data.from_pandas(df).repartition(2)
  
file_path: statsforecast/action_files/test_ray.py
imports: import sys
  import pytest
  import ray
  from .utils import pipeline, pipeline_with_level, pipeline_fitted
label_desc: Use image node_id 1 for calling a global function with example usage: to_distributed(df) and returns: ray