We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f6d2168 commit 79c9968Copy full SHA for 79c9968
test/fixtures.py
@@ -156,6 +156,7 @@ def open(self):
156
timeout = min(timeout, max(end_at - time.time(), 0))
157
if self.child.wait_for(r"binding to port", timeout=timeout):
158
break
159
+ self.child.dump_logs()
160
self.child.stop()
161
timeout *= 2
162
time.sleep(backoff)
@@ -305,6 +306,7 @@ def open(self):
305
306
if self.child.wait_for(r"\[Kafka Server %d\], Started" %
307
self.broker_id, timeout=timeout):
308
309
310
311
312
0 commit comments