code: def test_enable_batch_adjlist_replication_weights(
      graph_file, directed, dask_client
  ):
      gc.collect()
      df = cudf.read_csv(
          graph_file,
          delimiter=" ",
          names=["src", "dst", "value"],
          dtype=["int32", "int32", "float32"],
      )
      G = cugraph.Graph(directed=directed)
      G.from_cudf_edgelist(
          df, source="src", destination="dst", edge_attr="value"
      )
      G.enable_batch()
      G.view_adj_list()
      adjlist = G.adjlist
      offsets = adjlist.offsets
      indices = adjlist.indices
      weights = adjlist.weights
      for worker in G.batch_adjlists:
          (rep_offsets, rep_indices, rep_weights) = G.batch_adjlists[
              worker
          ]
          assert_series_equal(
              offsets, rep_offsets.result(), check_names=False
          )
          assert_series_equal(
              indices, rep_indices.result(), check_names=False
          )
          assert_series_equal(
              weights, rep_weights.result(), check_names=False
          )
  
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 10 for calling a global function with example usage: test_enable_batch_adjlist_replication_weights(graph_file, directed, dask_client) without return types