Convert into an array of :class:`dask.delayed.Delayed` objects, one per chunk. Parameters ---------- optimize_graph : bool, optional If True [default], the graph is optimized before converting into :class:`dask.delayed.Delayed` objects. See A
(self, optimize_graph=True)
| 2959 | return c |
| 2960 | |
| 2961 | def to_delayed(self, optimize_graph=True): |
| 2962 | """Convert into an array of :class:`dask.delayed.Delayed` objects, one per chunk. |
| 2963 | |
| 2964 | Parameters |
| 2965 | ---------- |
| 2966 | optimize_graph : bool, optional |
| 2967 | If True [default], the graph is optimized before converting into |
| 2968 | :class:`dask.delayed.Delayed` objects. |
| 2969 | |
| 2970 | See Also |
| 2971 | -------- |
| 2972 | dask.array.from_delayed |
| 2973 | """ |
| 2974 | keys = self.__dask_keys__() |
| 2975 | graph = self.__dask_graph__() |
| 2976 | layer = self.__dask_layers__()[0] |
| 2977 | if optimize_graph: |
| 2978 | graph = self.__dask_optimize__(graph, keys) # TODO, don't collape graph |
| 2979 | layer = "delayed-" + self.name |
| 2980 | graph = HighLevelGraph.from_collections(layer, graph, dependencies=()) |
| 2981 | L = ndeepmap(self.ndim, lambda k: Delayed(k, graph, layer=layer), keys) |
| 2982 | return np.array(L, dtype=object) |
| 2983 | |
| 2984 | def repeat(self, repeats, axis=None): |
| 2985 | """Repeat elements of an array. |