summaryrefslogtreecommitdiff
path: root/test/service.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2015-06-09 14:21:13 -0700
committerDana Powers <dana.powers@gmail.com>2015-06-09 14:21:13 -0700
commita74fa06b56584b05a3f2789e4643b83eca4e0b4b (patch)
treeb7d69313ac30c03545a6aa89ba9414e6f75abffe /test/service.py
parent742cd5ee249c3ad315e97ec389019a11bf1f64ea (diff)
parent0e416d528767a1246c72ae1efa917e401cedd79f (diff)
downloadkafka-python-a74fa06b56584b05a3f2789e4643b83eca4e0b4b.tar.gz
Merge pull request #397 from dpkp/test_logging
Test logging
Diffstat (limited to 'test/service.py')
-rw-r--r--test/service.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/test/service.py b/test/service.py
index 9368b85..b986a71 100644
--- a/test/service.py
+++ b/test/service.py
@@ -59,7 +59,8 @@ class SpawnedService(threading.Thread):
self.alive = True
def _despawn(self):
- self.child.terminate()
+ if self.child.poll() is None:
+ self.child.terminate()
self.alive = False
for _ in range(50):
if self.child.poll() is not None: