diff options
| author |  Ken Payson <kpayson@google.com> | 2016-07-11 17:15:29 -0700 |
|---|---|---|
| committer | Ken Payson <kpayson@google.com> | 2016-07-11 22:04:40 -0700 |
| commit | b5b6f93e005798295044b5691a45e35e7a2d9303 (patch) | |
| tree | fcb8dcc5824c6ce837d5b186b89f299411f83eec /src | |
| parent | 7126163b92c4b6be0ed8f9954e29fd9965cd7bb6 (diff) | |
Updated python qps tests to use GA server API
This should have been included as part of
45c0f2b3051bf1642337e109df57e8031cb654c8
Diffstat (limited to 'src')
| -rw-r--r-- | src/python/grpcio_tests/tests/qps/qps_worker.py | 2 | ||||
| -rw-r--r-- | src/python/grpcio_tests/tests/qps/worker_server.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/python/grpcio_tests/tests/qps/qps_worker.py b/src/python/grpcio_tests/tests/qps/qps_worker.py index 3abf0d08dd..2371ff0956 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 @@ from tests.qps import worker_server 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)) diff --git a/src/python/grpcio_tests/tests/qps/worker_server.py b/src/python/grpcio_tests/tests/qps/worker_server.py index 932a1ffe2b..46d542940f 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 @@ class WorkerServer(services_pb2.WorkerServiceServicer): 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() |