dask.bag.Item.visualize

dask.bag.Item.visualize¶

Item.visualize(filename='mydask', format=None, optimize_graph=False, **kwargs)¶

Render the computation of this object’s task graph using graphviz.

Requires graphviz to be installed.

Parameters

filenamestr or None, optional: The name of the file to write to disk. If the provided filename doesn’t include an extension, ‘.png’ will be used by default. If filename is None, no file will be written, and we communicate with dot using only pipes.
format{‘png’, ‘pdf’, ‘dot’, ‘svg’, ‘jpeg’, ‘jpg’}, optional: Format in which to write output file. Default is ‘png’.
optimize_graphbool, optional: If True, the graph is optimized before rendering. Otherwise, the graph is displayed as is. Default is False.
color: {None, ‘order’}, optional: Options to color nodes. Provide cmap= keyword for additional colormap
**kwargs: Additional keyword arguments to forward to to_graphviz.

Returns

resultIPython.diplay.Image, IPython.display.SVG, or None: See dask.dot.dot_graph for more information.

See also

Notes

For more information on optimization see here:

Examples

>>> x.visualize(filename='dask.pdf')  
>>> x.visualize(filename='dask.pdf', color='order')  

dask.bag.Item.to_delayed

Dask DataFrame