File tree Expand file tree Collapse file tree 4 files changed +354
-55
lines changed
codeflare_pipelines.egg-info Expand file tree Collapse file tree 4 files changed +354
-55
lines changed Original file line number Diff line number Diff line change
1
+ import graphviz
2
+ import codeflare .pipelines .Datamodel as dm
3
+
4
+
5
+ def pipeline_to_graph (pipeline : dm .Pipeline ) -> graphviz .Digraph :
6
+ """
7
+ Converts the given pipeline to a networkX graph for visualization.
8
+
9
+ :param pipeline: Pipeline to convert to networkX graph
10
+ :return: A directed graph representing this pipeline
11
+ """
12
+ graph = graphviz .Digraph ()
13
+ pipeline_nodes = pipeline .get_nodes ()
14
+ for pre_node in pipeline_nodes .values ():
15
+ post_nodes = pipeline .get_post_nodes (pre_node )
16
+ graph .node (pre_node .get_node_name ())
17
+ for post_node in post_nodes :
18
+ graph .node (post_node .get_node_name ())
19
+ graph .edge (pre_node .get_node_name (), post_node .get_node_name ())
20
+ return graph
Original file line number Diff line number Diff line change @@ -5,6 +5,7 @@ codeflare/pipelines/Datamodel.py
5
5
codeflare/pipelines/Exceptions.py
6
6
codeflare/pipelines/Runtime.py
7
7
codeflare/pipelines/__init__.py
8
+ codeflare/pipelines/utils.py
8
9
codeflare_pipelines.egg-info/PKG-INFO
9
10
codeflare_pipelines.egg-info/SOURCES.txt
10
11
codeflare_pipelines.egg-info/dependency_links.txt
You can’t perform that action at this time.
0 commit comments