code: def test_dask_mg_k_core(
      dask_client, benchmark, input_expected_output
  ):
      dg = input_expected_output["MGGraph"]
      core_number = input_expected_output["core_number"]
  
      k_core_results = benchmark(
          dcg.k_core, dg, core_number=core_number
      )
  
      expected_k_core_results = input_expected_output[
          "sg_k_core_results"
      ]
  
      k_core_results = (
          k_core_results.compute()
          .sort_values(["src", "dst"])
          .reset_index(drop=True)
          .rename(columns={"weights": "weight"})
      )
  
      assert_frame_equal(
          expected_k_core_results,
          k_core_results,
          check_dtype=False,
          check_like=True,
      )
  
file_path: cugraph/python/cugraph/cugraph/tests/core/test_k_core_mg.py
imports: import gc
  import pytest
  import dask_cudf
  import cugraph
  import cugraph.dask
  from cugraph.testing import utils
  from cudf.testing.testing import assert_frame_equal
  from cugraph.structure.symmetrize import symmetrize_df
  from pylibcugraph.testing import gen_fixture_params_product
label_desc: Use image node_id 5 for calling a global function with example usage: test_dask_mg_k_core(dask_client, benchmark, input_expected_output) without return types