Merge pull request #451 from Parsely/redis-example-fixes

Import fixes for redis examples
pystorm · Oct 17, 2018 · 361088f · 361088f
2 parents f3fb5a9 + e241cde
commit 361088f
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/.gitignore b/.gitignore
@@ -14,3 +14,5 @@ _resources/
 .tox/
 .python-version
 .*.un~
+
+\.idea/
diff --git a/examples/redis/topologies/wordcount_mem.py b/examples/redis/topologies/wordcount_mem.py
@@ -2,13 +2,12 @@
 Word count topology (in memory)
 """
 
+from src.bolts import WordCountBolt
+from src.spouts import WordSpout
 from streamparse import Grouping, Topology
 
-from bolts import WordCountBolt
-from spouts import WordSpout
-
 
 class WordCount(Topology):
     word_spout = WordSpout.spec()
-    count_bolt = WordCountBolt.spec(inputs={word_spout: Grouping.fields('word')},
-                                    par=2)
+    count_bolt = WordCountBolt.spec(
+        inputs={word_spout: Grouping.fields('word')}, par=2)
diff --git a/examples/redis/topologies/wordcount_redis.py b/examples/redis/topologies/wordcount_redis.py
@@ -2,11 +2,10 @@
 Word count topology (in Redis)
 """
 
+from src.bolts import RedisWordCountBolt
+from src.spouts import WordSpout
 from streamparse import Topology
 
-from bolts import RedisWordCountBolt
-from spouts import WordSpout
-
 
 class WordCount(Topology):
     word_spout = WordSpout.spec()