diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-02-08 12:06:26 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-02-08 12:06:26 -0800 |
| commit | 0a3799d599a098d6cf411e9a9a721f4b70056898 (patch) | |
| tree | 6bd8ea9dfb9d57bbafd6993d1eec985df9186c2f | |
| parent | ea9f2e6a9d7fb8419b1e6713c150d9ea404a1676 (diff) | |
| download | kafka-python-0a3799d599a098d6cf411e9a9a721f4b70056898.tar.gz | |
Increase some testing timeouts
| -rw-r--r-- | test/fixtures.py | 6 | ||||
| -rw-r--r-- | test/test_consumer_integration.py | 10 |
2 files changed, 10 insertions, 6 deletions
diff --git a/test/fixtures.py b/test/fixtures.py index 62c6d50..1c418fd 100644 --- a/test/fixtures.py +++ b/test/fixtures.py @@ -141,7 +141,7 @@ class ZookeeperFixture(Fixture): # Party! timeout = 5 - max_timeout = 30 + max_timeout = 120 backoff = 1 end_at = time.time() + max_timeout tries = 1 @@ -161,6 +161,7 @@ class ZookeeperFixture(Fixture): timeout *= 2 time.sleep(backoff) tries += 1 + backoff += 1 else: raise RuntimeError('Failed to start Zookeeper before max_timeout') self.out("Done!") @@ -278,7 +279,7 @@ class KafkaFixture(Fixture): env = self.kafka_run_class_env() timeout = 5 - max_timeout = 30 + max_timeout = 120 backoff = 1 end_at = time.time() + max_timeout tries = 1 @@ -301,6 +302,7 @@ class KafkaFixture(Fixture): timeout *= 2 time.sleep(backoff) tries += 1 + backoff += 1 else: raise RuntimeError('Failed to start KafkaInstance before max_timeout') self.out("Done!") diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py index ded2314..40eec14 100644 --- a/test/test_consumer_integration.py +++ b/test/test_consumer_integration.py @@ -647,13 +647,14 @@ class TestConsumerIntegration(KafkaIntegrationTestCase): early_time = late_time - 2000 tp = TopicPartition(self.topic, 0) + timeout = 10 kafka_producer = self.kafka_producer() early_msg = kafka_producer.send( self.topic, partition=0, value=b"first", - timestamp_ms=early_time).get(1) + timestamp_ms=early_time).get(timeout) late_msg = kafka_producer.send( self.topic, partition=0, value=b"last", - timestamp_ms=late_time).get(1) + timestamp_ms=late_time).get(timeout) consumer = self.kafka_consumer() offsets = consumer.offsets_for_times({tp: early_time}) @@ -699,12 +700,13 @@ class TestConsumerIntegration(KafkaIntegrationTestCase): kafka_producer = self.kafka_producer() send_time = int(time.time() * 1000) + timeout = 10 p0msg = kafka_producer.send( self.topic, partition=0, value=b"XXX", - timestamp_ms=send_time).get() + timestamp_ms=send_time).get(timeout) p1msg = kafka_producer.send( self.topic, partition=1, value=b"XXX", - timestamp_ms=send_time).get() + timestamp_ms=send_time).get(timeout) consumer = self.kafka_consumer() offsets = consumer.offsets_for_times({ |