def generate_raw_partd_file(compression):
    df1 = pd.DataFrame({'a': list(range(10000))})
    df1['b'] = (df1['a'] * 123).astype(str)
    with dask.config.set({'dataframe.shuffle-compression': compression}):
        p1 = maybe_buffered_partd(buffer=False, tempdir=None)()
        p1.append({'x': df1})
        filename = (p1.partd.partd.filename('x') if compression else p1.partd.filename('x'))
        with open(filename, 'rb') as f:
            return f.read()
def generate_raw_partd_file(compression):
    df1 = pd.DataFrame({'a': list(range(10000))})
    df1['b'] = (df1['a'] * 123).astype(str)
    with dask.config.set({'dataframe.shuffle-compression': compression}):
        p1 = maybe_buffered_partd(buffer=False, tempdir=None)()
        p1.append({'x': df1})
        filename = (p1.partd.partd.filename('x') if compression else p1.partd.filename('x'))
        with open(filename, 'rb') as f:
            return f.read()