diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-03-14 09:28:43 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-03-14 09:28:43 -0700 |
| commit | c902baafbee777ec65fc66c9fdbaa5b172b37917 (patch) | |
| tree | ecca5d9edf5a2ad2c589223c4a92951149bc59c4 /test | |
| parent | 98ca3a6ab5ee7eada31236f3665ae43d21defee0 (diff) | |
| download | kafka-python-c902baafbee777ec65fc66c9fdbaa5b172b37917.tar.gz | |
Re-render fixture config in restart loop if necessary
Diffstat (limited to 'test')
| -rw-r--r-- | test/fixtures.py | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/test/fixtures.py b/test/fixtures.py index 0b75ffd..e25ac22 100644 --- a/test/fixtures.py +++ b/test/fixtures.py @@ -148,6 +148,11 @@ class ZookeeperFixture(Fixture): tries = 1 while time.time() < end_at: self.out('Attempting to start (try #%d)' % tries) + try: + os.stat(properties) + except: + log.warning('Config %s not found -- re-rendering', properties) + self.render_template(template, properties, vars(self)) self.child = SpawnedService(args, env) self.child.start() timeout = min(timeout, max(end_at - time.time(), 0)) @@ -273,6 +278,11 @@ class KafkaFixture(Fixture): tries = 1 while time.time() < end_at: self.out('Attempting to start (try #%d)' % tries) + try: + os.stat(properties) + except: + log.warning('Config %s not found -- re-rendering', properties) + self.render_template(template, properties, vars(self)) self.child = SpawnedService(args, env) self.child.start() timeout = min(timeout, max(end_at - time.time(), 0)) |