code: def test_spark_flow_with_level(horizon, sample_data, n_series):
      pipeline_with_level(*sample_data, n_series, horizon)
  
file_path: statsforecast/action_files/test_spark.py
imports: import sys
  import pytest
  from pyspark.sql import SparkSession
  from .utils import pipeline, pipeline_with_level, pipeline_fitted
label_desc: Use image node_id 5 for calling a global function with example usage: test_spark_flow_with_level(horizon, sample_data, n_series) without return types