commit a09219c3b6628c47c49d7001f47aab5ec2da7d2d
author kpayson64 <kpayson@google.com> Mon Jul 11 23:44:37 2016 -0700
committer GitHub <noreply@github.com> Mon Jul 11 23:44:37 2016 -0700
tree b89c513223841ba7430aa083697613aecda857c4
parent b6f760f425f93c511139649ea43ae674f1cbddb1
parent b5b6f93e005798295044b5691a45e35e7a2d9303

Merge pull request #7323 from kpayson64/fix_py_qps

Updated python qps tests to use GA server API

src/python/grpcio_tests/tests/qps/qps_worker.py

diff --git a/src/python/grpcio_tests/tests/qps/qps_worker.py b/src/python/grpcio_tests/tests/qps/qps_worker.py
index 3abf0d0..2371ff0 100644
--- a/src/python/grpcio_tests/tests/qps/qps_worker.py
+++ b/src/python/grpcio_tests/tests/qps/qps_worker.py
@@ -40,7 +40,7 @@
 
 
 def run_worker_server(port):
-  server = grpc.server((), futures.ThreadPoolExecutor(max_workers=5))
+  server = grpc.server(futures.ThreadPoolExecutor(max_workers=5))
   servicer = worker_server.WorkerServer()
   services_pb2.add_WorkerServiceServicer_to_server(servicer, server)
   server.add_insecure_port('[::]:{}'.format(port))

src/python/grpcio_tests/tests/qps/worker_server.py

diff --git a/src/python/grpcio_tests/tests/qps/worker_server.py b/src/python/grpcio_tests/tests/qps/worker_server.py
index 932a1ff..46d5429 100644
--- a/src/python/grpcio_tests/tests/qps/worker_server.py
+++ b/src/python/grpcio_tests/tests/qps/worker_server.py
@@ -82,7 +82,7 @@
       server_threads = multiprocessing.cpu_count() * 5
     else:
       server_threads = config.async_server_threads
-    server = grpc.server((), futures.ThreadPoolExecutor(
+    server = grpc.server(futures.ThreadPoolExecutor(
         max_workers=server_threads))
     if config.server_type == control_pb2.ASYNC_SERVER:
       servicer = benchmark_server.BenchmarkServer()