code: def _call_plc_replicate_series(
      sID: bytes, series: cudf.Series
  ) -> cudf.Series:
      series = series[0]
      series_replicated = cudf.Series()
      cp_array = pylibcugraph_replicate_edgelist(
          resource_handle=ResourceHandle(
              Comms.get_handle(sID).getHandle()
          ),
          src_array=series
          if series.dtype in [np.int32, np.int64]
          else None,
          dst_array=None,
          weight_array=series
          if series.dtype in [np.float32, np.float64]
          else None,
          edge_id_array=None,
          edge_type_id_array=None,
      )
      src, _, wgt, _, _, _ = cp_array
      if src is not None:
          series_replicated = cudf.Series(src)
      elif wgt is not None:
          series_replicated = cudf.Series(wgt)
  
      return series_replicated
  
file_path: cugraph/python/cugraph/cugraph/structure/replicate_edgelist.py
imports: import dask_cudf
  import cudf
  from dask.distributed import wait, default_client
  import numpy
  from pylibcugraph import ResourceHandle, replicate_edgelist
  from cugraph.dask.common.part_utils import get_persisted_df_worker_map, persist_dask_df_equal_parts_per_worker
  import dask
  import cupy
  import cugraph.dask.comms.comms
  from typing import Union, Tuple
label_desc: Use image node_id 4 for calling a global function with example usage: _call_plc_replicate_series(sID, series) and returns: series_replicated