File tree Expand file tree Collapse file tree 1 file changed +12
-4
lines changed
Expand file tree Collapse file tree 1 file changed +12
-4
lines changed Original file line number Diff line number Diff line change
8000
@@ -62,10 +62,18 @@ def view(*streams, **kwargs):
6262
6363 for edge in get_outgoing_edges (node , outgoing_edge_map ):
6464 kwargs = {}
65- if show_labels and (edge .upstream_label is not None or edge .downstream_label is not None ):
66- upstream_label = edge .upstream_label if edge .upstream_label is not None else ''
67- downstream_label = edge .downstream_label if edge .downstream_label is not None else ''
68- kwargs ['label' ] = '{} {}' .format (upstream_label , downstream_label )
65+ up_label = edge .upstream_label
66+ down_label = edge .downstream_label
67+ if show_labels and (up_label is not None or down_label is not None ):
68+ if up_label is None :
69+ up_label = ''
70+ if down_label is None :
71+ down_label = ''
72+ if up_label != '' and down_label != '' :
73+ middle = ' -> '
74+ else :
75+ middle = ''
76+ kwargs ['label' ] = '{} {} {}' .format (up_label , middle , down_label )
6977 upstream_node_id = str (hash (edge .upstream_node ))
7078 downstream_node_id = str (hash (edge .downstream_node ))
7179 graph .edge (upstream_node_id , downstream_node_id , ** kwargs )
You can’t perform that action at this time.
0 commit comments