diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-02-08 23:39:37 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-02-08 23:39:37 -0800 |
| commit | 8655c75e6a147080235d3458ec82edb9e1ff78a6 (patch) | |
| tree | ec9c607a83f74962d557117ab5f561b146332999 /test/fixtures.py | |
| parent | 7d8f9a41e0b7a83624e6ebab368de68b87f71997 (diff) | |
| download | kafka-python-8655c75e6a147080235d3458ec82edb9e1ff78a6.tar.gz | |
Increase some integration test timeouts (#1374)
Diffstat (limited to 'test/fixtures.py')
| -rw-r--r-- | test/fixtures.py | 6 |
1 files changed, 4 insertions, 2 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!") |