code: def symmetrize_ddf(dask_dataframe):
      source_col, dest_col = symmetrize(
          dask_dataframe,
          "src",
          "dst",
          multi=True,
          symmetrize=True,
      )
  
      new_ddf = source_col.to_frame()
      new_ddf["dst"] = dest_col
  
      return new_ddf
  
imports: import logging
  import warnings
  import argparse
  import traceback
  from cugraph.testing.mg_utils import generate_edgelist_rmat, get_allocation_counts_dask_lazy, sizeof_fmt, get_peak_output_ratio_across_workers, start_dask_client, stop_dask_client, enable_spilling
  from cugraph.structure.symmetrize import symmetrize
  from cugraph.gnn import BulkSampler
  import cugraph
  import json
  import re
  import os
  import gc
  from time import sleep, perf_counter
  from math import ceil
  import pandas
  import numpy
  import cupy
  import cudf
  import dask_cudf
  import dask.dataframe
  from dask.distributed import default_client
  from cugraph.dask import get_n_workers
  from typing import Optional, Union, Dict
label_desc: Use image node_id 2 for calling a global function with example usage: symmetrize_ddf(dask_dataframe) and returns: new_ddf