code: def convert_to_cudf(cp_arrays: cp.ndarray) -> cudf.DataFrame:
      cp_src, cp_dst, cp_weight, cp_offsets = cp_arrays
  
      df = cudf.DataFrame()
      df["src"] = cp_src
      df["dst"] = cp_dst
      df["weight"] = cp_weight
  
      offsets = cudf.Series(cp_offsets)
  
      return consolidate_results(df, offsets)
  
file_path: cugraph/python/cugraph/cugraph/dask/community/induced_subgraph.py
imports: from dask.distributed import wait, default_client
  import cugraph.dask.comms.comms
  import dask_cudf
  import cudf
  import cupy
  from cugraph.dask.common.part_utils import persist_dask_df_equal_parts_per_worker
  from typing import Union, Tuple
  from pylibcugraph import ResourceHandle, induced_subgraph
label_desc: Use image node_id 3 for calling a global function with example usage: convert_to_cudf(cp_arrays) and returns: consolidate_results