diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-09 16:37:40 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-09 16:37:40 -0700 |
| commit | f6be28372cffc6ddc675905f67bf3aa1f1716bf9 (patch) | |
| tree | 1ca492c42b7b3d7fed18e8dc9b2fdf1e998b7eaf | |
| parent | a74fa06b56584b05a3f2789e4643b83eca4e0b4b (diff) | |
| download | kafka-python-f6be28372cffc6ddc675905f67bf3aa1f1716bf9.tar.gz | |
Create a new child thread on each open fixture try
| -rw-r--r-- | test/fixtures.py | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/test/fixtures.py b/test/fixtures.py index 4231452..d4d03ee 100644 --- a/test/fixtures.py +++ b/test/fixtures.py @@ -122,11 +122,11 @@ class ZookeeperFixture(Fixture): # Configure Zookeeper child process args = self.kafka_run_class_args("org.apache.zookeeper.server.quorum.QuorumPeerMain", properties) env = self.kafka_run_class_env() - self.child = SpawnedService(args, env) # Party! self.out("Starting...") while True: + self.child = SpawnedService(args, env) self.child.start() if self.child.wait_for(r"binding to port", timeout=5): break @@ -202,11 +202,6 @@ class KafkaFixture(Fixture): properties = os.path.join(self.tmp_dir, "kafka.properties") self.render_template(template, properties, vars(self)) - # Configure Kafka child process - args = self.kafka_run_class_args("kafka.Kafka", properties) - env = self.kafka_run_class_env() - self.child = SpawnedService(args, env) - # Party! self.out("Creating Zookeeper chroot node...") args = self.kafka_run_class_args("org.apache.zookeeper.ZooKeeperMain", @@ -225,7 +220,13 @@ class KafkaFixture(Fixture): self.out("Done!") self.out("Starting...") + + # Configure Kafka child process + args = self.kafka_run_class_args("kafka.Kafka", properties) + env = self.kafka_run_class_env() + while True: + self.child = SpawnedService(args, env) self.child.start() if self.child.wait_for(r"\[Kafka Server %d\], Started" % self.broker_id, timeout=5): break |