summaryrefslogtreecommitdiff
path: root/test/service.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2014-08-13 09:47:03 -0700
committerDana Powers <dana.powers@rd.io>2014-08-13 09:47:03 -0700
commita6200f2e998c9cc17ca5f247798478a84956a2e2 (patch)
tree58e1305be40e7a34ddedc56a8557d3b35554bf1d /test/service.py
parent4796d58792a0f190ced62e8e4a7d5e20867f735b (diff)
downloadkafka-python-a6200f2e998c9cc17ca5f247798478a84956a2e2.tar.gz
Increase fixture wait timeout to 30s; add wait-time logging
Diffstat (limited to 'test/service.py')
-rw-r--r--test/service.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/test/service.py b/test/service.py
index 2c667c7..df6c1ba 100644
--- a/test/service.py
+++ b/test/service.py
@@ -80,7 +80,7 @@ class SpawnedService(threading.Thread):
for line in self.captured_stdout:
logging.critical(line.rstrip())
- def wait_for(self, pattern, timeout=10):
+ def wait_for(self, pattern, timeout=30):
t1 = time.time()
while True:
t2 = time.time()
@@ -91,11 +91,13 @@ class SpawnedService(threading.Thread):
logging.exception("Received exception when killing child process")
self.dump_logs()
- raise RuntimeError("Waiting for %r timed out" % pattern)
+ raise RuntimeError("Waiting for %r timed out after %d seconds" % (pattern, timeout))
if re.search(pattern, '\n'.join(self.captured_stdout), re.IGNORECASE) is not None:
+ logging.info("Found pattern %r in %d seconds via stdout", pattern, (t2 - t1))
return
if re.search(pattern, '\n'.join(self.captured_stderr), re.IGNORECASE) is not None:
+ logging.info("Found pattern %r in %d seconds via stderr", pattern, (t2 - t1))
return
time.sleep(0.1)