apache_beam.runners.interactive.display.pipeline_graph module¶

For generating Beam pipeline graph in DOT representation.

This module is experimental. No backwards-compatibility guarantees.

class apache_beam.runners.interactive.display.pipeline_graph.PipelineGraph(pipeline, default_vertex_attrs=None, default_edge_attrs=None)[source]¶

Bases: object

Creates a DOT representation of the pipeline. Thread-safe.

Constructor of PipelineGraph.

Examples

graph = pipeline_graph.PipelineGraph(pipeline_proto) graph.display_graph()

or

graph = pipeline_graph.PipelineGraph(pipeline) graph.display_graph()

Parameters:	pipeline – (Pipeline proto) or (Pipeline) pipeline to be rendered. default_vertex_attrs – (Dict[str, str]) a dict of default vertex attributes default_edge_attrs – (Dict[str, str]) a dict of default edge attributes

get_dot()[source]¶