code: def test_replicate_cudf_series(input_data_path, dask_client):
      gc.collect()
      df = cudf.read_csv(
          input_data_path,
          delimiter=" ",
          names=["src", "dst", "value"],
          dtype=["int32", "int32", "float32"],
      )
      for column in df.columns.values:
          series = df[column]
          worker_to_futures = replication.replicate_cudf_series(series)
          for worker in worker_to_futures:
              replicated_series = worker_to_futures[worker].result()
              assert_series_equal(
                  series, replicated_series, check_names=False
              )
          # FIXME: If we do not clear this dictionary, when comparing
          # results for the 2nd column, one of the workers still
          # has a value from the 1st column
          worker_to_futures = {}
  
file_path: cugraph/python/cugraph/cugraph/tests/utils/test_replication_mg.py
imports: import gc
  import pytest
  import cudf
  import cugraph
  import cugraph.testing.utils
  import cugraph.dask.structure.replication
  from cugraph.dask.common.mg_utils import is_single_gpu
  from cudf.testing import assert_series_equal, assert_frame_equal
label_desc: Use image node_id 3 for calling a global function with example usage: test_replicate_cudf_series(input_data_path, dask_client) without return types