Fix the multiprocessing tests for python 3

Mark Roberts · Mark Roberts · commit 84a7add6da7d · 2014-09-03T11:46:39.000-07:00
diff --git a/kafka/consumer.py b/kafka/consumer.py
@@ -591,7 +591,7 @@ def __init__(self, client, group, topic, auto_commit=True,
         for chunk in chunks:
             chunk = filter(lambda x: x is not None, chunk)
             args = (client.copy(),
-                    group, topic, chunk,
+                    group, topic, list(chunk),
                     self.queue, self.start, self.exit,
                     self.pause, self.size)
 
diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py
@@ -151,7 +151,7 @@ def test_multi_process_consumer_blocking(self):
         with Timer() as t:
             messages = consumer.get_messages(count=10, block=True, timeout=5)
             self.assert_message_count(messages, 5)
-        self.assertGreaterEqual(t.interval, 5)
+        self.assertGreaterEqual(t.interval, 4.95)
 
         consumer.stop()
 
diff --git a/tox.ini b/tox.ini
@@ -9,7 +9,7 @@ deps =
     mock
     python-snappy
 commands =
-    nosetests {posargs:-v --with-id --with-timer --timer-top-n 10 --with-coverage --cover-erase --cover-package kafka}
+    nosetests {posargs:-v --with-id --id-file={envdir}/.noseids --with-timer --timer-top-n 10 --with-coverage --cover-erase --cover-package kafka}
 setenv =
     PROJECT_ROOT = {toxinidir}
 
