Method __dask_postcompute__

dask/dataframe/dask_expr/_collection.py:576–580

(self)

        return new_collection(self.expr.optimize(fuse=fuse))

    def __dask_postcompute__(self):
        state = new_collection(self.expr.lower_completely())
        if type(self) != type(state):
            return state.__dask_postcompute__()
        return _concat, ()

    @staticmethod
    def _postpersist(futures, meta, divisions, name):