Source code for tributary.streaming.base



[docs]class StreamingGraph(object): def __init__(self, output_node): self._node = output_node
[docs] def graph(self): return self._node.graph()
[docs] def graphviz(self): return self._node.graphviz()
[docs] def dagre(self): return self._node.dagre()
[docs] def run(self): from tributary.streaming import run return run(self._node)