code: def test_bag(setup_cluster):
      import dask
  
      b = dask.datasets.make_people()  # Make records of people
      result = (
          b.filter(lambda record: record["age"] > 30)
          .map(lambda record: record["occupation"])
          .frequencies(sort=True)
          .topk(10, key=1)
      )
  
      dask_res = result.compute()
      assert dask_res == result.compute(scheduler=mars_scheduler)
      assert (
          dask_res == convert_dask_collection(result).execute().fetch()
      )
  
file_path: mars/mars/contrib/dask/tests/test_dask.py
imports: import pytest
  from ....utils import lazy_import
  from ..None import convert_dask_collection, mars_scheduler
label_desc: Use image node_id 5 for calling a global function with example usage: test_bag(setup_cluster) without return types