aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/python/grpcio/tests/qps/worker_server.py
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2016-06-20 08:09:52 -0700
committerGravatar Craig Tiller <ctiller@google.com>2016-06-20 08:09:52 -0700
commita4d2d0c798a182d5cc57ce630d31614173f2d67b (patch)
treea1f0f4e324f8bc65ced4e7b49af3af266f6ad900 /src/python/grpcio/tests/qps/worker_server.py
parentccc8ec54b0cf75f52c0a19a2674d6a6bc8e93743 (diff)
parent4e29480e430b94392105934750adfd85cb7849ce (diff)
Merge github.com:grpc/grpc into reuse_port
Diffstat (limited to 'src/python/grpcio/tests/qps/worker_server.py')
-rw-r--r--src/python/grpcio/tests/qps/worker_server.py5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/python/grpcio/tests/qps/worker_server.py b/src/python/grpcio/tests/qps/worker_server.py
index 1f9af5482c..d41f8377c2 100644
--- a/src/python/grpcio/tests/qps/worker_server.py
+++ b/src/python/grpcio/tests/qps/worker_server.py
@@ -153,9 +153,8 @@ class WorkerServer(services_pb2.BetaWorkerServiceServicer):
if config.rpc_type == control_pb2.UNARY:
client = benchmark_client.UnaryAsyncBenchmarkClient(
server, config, qps_data)
- elif config.rpc_type == control_pb2.STREAMING:
- client = benchmark_client.StreamingAsyncBenchmarkClient(
- server, config, qps_data)
+ else:
+ raise Exception('Async streaming client not supported')
else:
raise Exception('Unsupported client type {}'.format(config.client_type))