Permalink
Browse files

fixed dependencies and some typos

  • Loading branch information...
1 parent f876cc4 commit 585c691308050c23f65713887b8325f695a236e4 @kadirpekel kadirpekel committed Mar 11, 2013
Showing with 7 additions and 7 deletions.
  1. +6 −7 octavious/tests.py
  2. +1 −0 requirements-dev.txt
View
@@ -78,19 +78,19 @@ def test_pipeline(self):
self.assertTrue(output['pre_processed_3'])
-class GeventTests(unittest.TestCase):
+class TestGeventParallelizer(unittest.TestCase):
def setUp(self):
try:
from octavious.parallelizer.gevent import GeventParallelizer
except ImportError:
self.skipTest("gevent library is not found.")
else:
- self.serializer_class = GeventParallelizer
+ self.parallelizer_class = GeventParallelizer
@patch("gevent.monkey.patch_all")
def test_monkey_patch(self, patch_all):
- self.serializer_class()
+ self.parallelizer_class()
patch_all.assert_any_call()
@patch("gevent.spawn")
@@ -105,13 +105,12 @@ def test_parallelizing(self, joinall, spawn):
def side_effect(callback):
callback(greenlet)
- greenlet.link = side_effect
+ greenlet.link.side_effect = side_effect
spawn.return_value = greenlet
processor = Mock()
- parallelizer = self.serializer_class(patch_builtins=False)
- results = parallelizer.parallelize(processors=[processor],
- input=input_value)
+ parallelizer = self.parallelizer_class(patch_builtins=False)
+ results = parallelizer(processors=[processor], input=input_value)
spawn.assert_called_with(processor, "foo")
joinall.assert_called_with([greenlet])
View
@@ -4,4 +4,5 @@ distribute
nose
pep8
pyflakes
+mock

0 comments on commit 585c691

Please sign in to comment.