code: def test_ray_flow_with_level(horizon, sample_data, n_series):
      pipeline_with_level(*sample_data, n_series, horizon)
  
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 4 for calling a global function with example usage: test_ray_flow_with_level(horizon, sample_data, n_series) without return types