Function _merge_chunk_wrapper

dask/dataframe/multi.py:360–366

(*args, **kwargs)

def _merge_chunk_wrapper(*args, **kwargs):
    return merge_chunk(
        *args,
        **{
            k: pickle.loads(v) if isinstance(v, bytes) else v for k, v in kwargs.items()
        },
    )