code: def test_array(setup_cluster):
      import dask.array as da
      from numpy.core.numeric import array_equal
  
      x = da.random.random((10000, 10000), chunks=(1000, 1000))
      y = x + x.T
      z = y[::2, 5000:].mean(axis=1)
  
      dask_res = z.compute()
      assert array_equal(dask_res, z.compute(scheduler=mars_scheduler))
      assert array_equal(
          dask_res, convert_dask_collection(z).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 4 for calling a global function with example usage: test_array(setup_cluster) without return types