code: def to_distributed(df):
      return dd.from_pandas(df, npartitions=2)
  
imports: import dask.dataframe
  import pytest
  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: dd