summaryrefslogtreecommitdiff
path: root/test/service.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2015-06-08 21:05:40 -0700
committerDana Powers <dana.powers@rd.io>2015-06-08 21:05:47 -0700
commitd262107aa870a72a15f7da097c116a8c6dcea0cd (patch)
tree2ca68b28cbfce6974e84c561ea4bc193b02f72fd /test/service.py
parent3d4d98ed78414af0c4330f056a3ae6bcf79ed11c (diff)
downloadkafka-python-d262107aa870a72a15f7da097c116a8c6dcea0cd.tar.gz
Retry with shorter 5sec timeout when trying to open() fixtures
- this is intended to reduce flapping tests caused by intermittent - fixture startup issues on travis-ci
Diffstat (limited to 'test/service.py')
-rw-r--r--test/service.py7
1 files changed, 4 insertions, 3 deletions
diff --git a/test/service.py b/test/service.py
index 7627322..9368b85 100644
--- a/test/service.py
+++ b/test/service.py
@@ -110,14 +110,15 @@ class SpawnedService(threading.Thread):
log.exception("Received exception when killing child process")
self.dump_logs()
- raise RuntimeError("Waiting for %r timed out after %d seconds" % (pattern, timeout))
+ log.error("Waiting for %r timed out after %d seconds", pattern, timeout)
+ return False
if re.search(pattern, '\n'.join(self.captured_stdout), re.IGNORECASE) is not None:
log.info("Found pattern %r in %d seconds via stdout", pattern, (t2 - t1))
- return
+ return True
if re.search(pattern, '\n'.join(self.captured_stderr), re.IGNORECASE) is not None:
log.info("Found pattern %r in %d seconds via stderr", pattern, (t2 - t1))
- return
+ return True
time.sleep(0.1)
def start(self):