Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions docs/source/index.rst
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,14 @@ flow of data. Typically people rely on tools like ``itertools.tee``, and
However this quickly become cumbersome, especially when building complex
pipelines.

Installation
------------

To install either use:

- conda-forge: ``conda install streamz -c conda-forge``
- pip: ``pip install streamz``
- dev: ``git clone https://github.com/python-streamz/streamz`` followed by ``pip install -e streamz/``

Related Work
------------
Expand Down
4 changes: 2 additions & 2 deletions streamz/graph.py
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,7 @@ def readable_graph(graph):
"""
import networkx as nx

mapping = {k: "{}".format(graph.node[k]["label"]) for k in graph}
mapping = {k: "{}".format(graph.nodes[k]["label"]) for k in graph}
idx_mapping = {}
for k, v in mapping.items():
if v in idx_mapping.keys():
Expand All @@ -132,7 +132,7 @@ def to_graphviz(graph, **graph_attr):
import graphviz

gvz = graphviz.Digraph(graph_attr=graph_attr)
for node, attrs in graph.node.items():
for node, attrs in graph.nodes.items():
gvz.node(node, **attrs)
for edge, attrs in graph.edges().items():
gvz.edge(edge[0], edge[1], **attrs)
Expand Down