def collect(group, p, meta, barrier_token):
    res = p.get(group)
    return res if len(res) > 0 else meta
Collect partitions from partd, yield dataframes
dataset/ETHPy150Open dask/dask/dask/dataframe/shuffle.py/collect