def test_shuffle(shuffle_method):
    s = shuffle_func(d, d.b, shuffle=shuffle_method)
    assert isinstance(s, dd.DataFrame)
    assert (s.npartitions == d.npartitions)
    x = dask.get(s.dask, (s._name, 0))
    y = dask.get(s.dask, (s._name, 1))
    assert (not (set(x.b) & set(y.b)))
    assert set(s.dask).issuperset(d.dask)
    assert (shuffle_func(d, d.b)._name == shuffle_func(d, d.b)._name)
def test_shuffle(shuffle_method):
    s = shuffle_func(d, d.b, shuffle=shuffle_method)
    assert isinstance(s, dd.DataFrame)
    assert (s.npartitions == d.npartitions)
    x = dask.get(s.dask, (s._name, 0))
    y = dask.get(s.dask, (s._name, 1))
    assert (not (set(x.b) & set(y.b)))
    assert set(s.dask).issuperset(d.dask)
    assert (shuffle_func(d, d.b)._name == shuffle_func(d, d.b)._name)