Method combine

dask/dataframe/dask_expr/_reductions.py:1342–1345

(cls, inputs: list, **kwargs)

    @classmethod
    def combine(cls, inputs: list, **kwargs):  # type: ignore
        func = cls.reduction_combine or cls.reduction_aggregate or cls.reduction_chunk
        df = _concat(inputs)
        return func(df, **kwargs)  # type: ignore

    def _divisions(self):
        # TODO: We can do better in some cases