code: def test_dask_flow(horizon, sample_data, n_series):
      renamer = {"unique_id": "id", "ds": "time", "y": "value"}
      series, X_df = sample_data
      series = series.rename(columns=renamer)
      X_df = X_df.rename(columns=renamer)
      pipeline(
          series,
          X_df,
          n_series,
          horizon,
          id_col="id",
          time_col="time",
          target_col="value",
      )
  
imports: import dask.dataframe
  import pytest
  from .utils import pipeline, pipeline_with_level, pipeline_fitted
label_desc: Use image node_id 3 for calling a global function with example usage: test_dask_flow(horizon, sample_data, n_series) without return types