kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: HOTFIX: rename run_test to execute in streams simple benchmark (#4941)
Date Fri, 27 Apr 2018 20:40:30 GMT
This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new b2e0812  HOTFIX: rename run_test to execute in streams simple benchmark (#4941)
b2e0812 is described below

commit b2e0812f6946f88cef2cdffb0be603b4b769033a
Author: Guozhang Wang <wangguoz@gmail.com>
AuthorDate: Fri Apr 27 13:40:24 2018 -0700

    HOTFIX: rename run_test to execute in streams simple benchmark (#4941)
---
 .../benchmarks/streams/streams_simple_benchmark_test.py      | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py b/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
index 6e6d676..b1cfb4e 100644
--- a/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
+++ b/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
@@ -107,22 +107,22 @@ class StreamsSimpleBenchmarkTest(Test):
 
         if test == ALL_TEST:
             for single_test in STREAMS_SIMPLE_TESTS + STREAMS_COUNT_TESTS + STREAMS_JOIN_TESTS:
-                self.run_test(single_test, scale)
+                self.execute(single_test, scale)
         elif test == STREAMS_SIMPLE_TEST:
             for single_test in STREAMS_SIMPLE_TESTS:
-                self.run_test(single_test, scale)
+                self.execute(single_test, scale)
         elif test == STREAMS_COUNT_TEST:
             for single_test in STREAMS_COUNT_TESTS:
-                self.run_test(single_test, scale)
+                self.execute(single_test, scale)
         elif test == STREAMS_JOIN_TEST:
             for single_test in STREAMS_JOIN_TESTS:
-                self.run_test(single_test, scale)
+                self.execute(single_test, scale)
         else:
-            self.run_test(test, scale)
+            self.execute(test, scale)
 
         return self.final
 
-    def run_test(self, test, scale):
+    def execute(self, test, scale):
 
         ################
         # RUN PHASE

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.

Mime
View raw message