kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: HOTFIX: Revert async change in ProduceConsumeValidateTest
Date Sat, 01 Oct 2016 00:16:32 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.1 abf056c08 -> 8ed595836


HOTFIX: Revert async change in ProduceConsumeValidateTest

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #1945 from hachikuji/hotfix-produce-consume-validate

(cherry picked from commit 788989158a466aa89f030940a28d4f868e275ed7)
Signed-off-by: Jason Gustafson <jason@confluent.io>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8ed59583
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8ed59583
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8ed59583

Branch: refs/heads/0.10.1
Commit: 8ed5958366c3ef7269fd363cde99b308d93fbd47
Parents: abf056c
Author: Jason Gustafson <jason@confluent.io>
Authored: Fri Sep 30 17:05:37 2016 -0700
Committer: Jason Gustafson <jason@confluent.io>
Committed: Fri Sep 30 17:16:30 2016 -0700

----------------------------------------------------------------------
 tests/kafkatest/tests/produce_consume_validate.py | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8ed59583/tests/kafkatest/tests/produce_consume_validate.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/tests/produce_consume_validate.py b/tests/kafkatest/tests/produce_consume_validate.py
index afb885d..9240f32 100644
--- a/tests/kafkatest/tests/produce_consume_validate.py
+++ b/tests/kafkatest/tests/produce_consume_validate.py
@@ -46,7 +46,7 @@ class ProduceConsumeValidateTest(Test):
     def setup_producer_and_consumer(self):
         raise NotImplementedError("Subclasses should implement this")
 
-    def start_producer_and_consumer(self, async=False):
+    def start_producer_and_consumer(self):
         # Start background producer and consumer
         self.consumer.start()
         if (self.consumer_init_timeout_sec > 0):
@@ -58,11 +58,11 @@ class ProduceConsumeValidateTest(Test):
                        self.consumer_init_timeout_sec)
 
         self.producer.start()
-        wait_until(lambda: async or self.producer.num_acked > 5,
+        wait_until(lambda: self.producer.num_acked > 5,
                    timeout_sec=self.producer_start_timeout_sec,
                    err_msg="Producer failed to produce messages for %ds." %\
                    self.producer_start_timeout_sec)
-        wait_until(lambda: async or len(self.consumer.messages_consumed[1]) > 0,
+        wait_until(lambda: len(self.consumer.messages_consumed[1]) > 0,
                    timeout_sec=self.consumer_start_timeout_sec,
                    err_msg="Consumer failed to consume messages for %ds." %\
                    self.consumer_start_timeout_sec)
@@ -89,10 +89,10 @@ class ProduceConsumeValidateTest(Test):
         self.producer.stop()
         self.consumer.wait()
 
-    def run_produce_consume_validate(self, async=False, core_test_action=None, *args):
+    def run_produce_consume_validate(self, core_test_action=None, *args):
         """Top-level template for simple produce/consume/validate tests."""
         try:
-            self.start_producer_and_consumer(async)
+            self.start_producer_and_consumer()
 
             if core_test_action is not None:
                 core_test_action(*args)


Mime
View raw message