@pytest.mark.parametrize('compression', ['UNKOWN_COMPRESSION_ALGO'])
def test_disk_shuffle_with_unknown_compression(compression):
    with dask.config.set({'dataframe.shuffle-compression': compression}):
        with pytest.raises(ImportError, match='Not able to import and load {} as compression algorithm.Please check if the library is installed and supported by Partd.'.format(compression)):
            test_shuffle('disk')
@pytest.mark.parametrize('compression', ['UNKOWN_COMPRESSION_ALGO'])
def test_disk_shuffle_with_unknown_compression(compression):
    with dask.config.set({'dataframe.shuffle-compression': compression}):
        with pytest.raises(ImportError, match='Not able to import and load {} as compression algorithm.Please check if the library is installed and supported by Partd.'.format(compression)):
            test_shuffle('disk')