Method aggregate

dask/dataframe/dask_expr/_reductions.py:816–819

(cls, inputs, **kwargs)

    @classmethod
    def aggregate(cls, inputs, **kwargs):
        func = cls.reduction_aggregate or cls.reduction_chunk
        df = _concat(inputs)
        return func(df, **kwargs)

    def __dask_postcompute__(self):
        return toolz.first, ()