code: def test_core_number(dask_client, benchmark, input_expected_output):
      dg = input_expected_output["MGGraph"]
      degree_type = input_expected_output["degree_type"]
  
      result_core_number = benchmark(dcg.core_number, dg, degree_type)
  
      result_core_number = (
          result_core_number.drop_duplicates()
          .compute()
          .sort_values("vertex")
          .reset_index(drop=True)
          .rename(columns={"core_number": "mg_core_number"})
      )
  
      expected_output = input_expected_output["sg_core_number_results"]
  
      # Update the mg core number with sg core number results
      # for easy comparison using cuDF DataFrame methods.
      result_core_number["sg_core_number"] = expected_output[
          "core_number"
      ]
      counts_diffs = result_core_number.query(
          "mg_core_number != sg_core_number"
      )
  
      assert len(counts_diffs) == 0
  
file_path: cugraph/python/cugraph/cugraph/tests/core/test_core_number_mg.py
imports: import gc
  import pytest
  import dask_cudf
  import cugraph
  import cugraph.dask
  from cugraph.testing import utils
  from pylibcugraph.testing.utils import gen_fixture_params_product
label_desc: Use image node_id 5 for calling a global function with example usage: test_core_number(dask_client, benchmark, input_expected_output) without return types