Method __array__

dask/dataframe/dask_expr/_collection.py:461–462

(self, dtype=None, **kwargs)

        )

    def __array__(self, dtype=None, **kwargs):
        return np.array(self.compute())

    def persist(self, fuse=True, **kwargs):
        out = self.optimize(fuse=fuse)