diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-04-22 19:08:13 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:48 +0300 |
| commit | 4c682f3d4da6c5af8bfbb00700c431a272b37dc1 (patch) | |
| tree | 4558bbbf8f64d82e5512d551ae67274bb2701df0 | |
| parent | 9eed1698fdcdda7cd8efe7bbee559ccf8baf9e1e (diff) | |
| download | kafka-python-4c682f3d4da6c5af8bfbb00700c431a272b37dc1.tar.gz | |
Increase producer test timeout
| -rw-r--r-- | test/test_producer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_producer.py b/test/test_producer.py index de012b9..3004c2d 100644 --- a/test/test_producer.py +++ b/test/test_producer.py @@ -158,7 +158,7 @@ class TestKafkaProducerSendUpstream(unittest.TestCase): self.client.send_produce_request.side_effect = send_side_effect - self._run_process(3, 2) + self._run_process(3, 3) # the queue should be void at the end of the test self.assertEqual(self.queue.empty(), True) |