Imported Upstream version 1.27.0

[platform/upstream/grpc.git] / src / python / grpcio_tests / tests / testing / _client_application.py

diff --git a/src/python/grpcio_tests/tests/testing/_client_application.py b/src/python/grpcio_tests/tests/testing/_client_application.py
index 4d42df0..57fa510 100644 (file)
--- a/src/python/grpcio_tests/tests/testing/_client_application.py
+++ b/src/python/grpcio_tests/tests/testing/_client_application.py
@@ -150,8 +150,8 @@ def _run_stream_stream(stub):
 
 def _run_concurrent_stream_unary(stub):
     future_calls = tuple(
-        stub.StreUn.future(
-            iter((_application_common.STREAM_UNARY_REQUEST,) * 3))
+        stub.StreUn.future(iter((_application_common.STREAM_UNARY_REQUEST,) *
+                                3))
         for _ in range(test_constants.THREAD_CONCURRENCY))
     for future_call in future_calls:
         if future_call.code() is grpc.StatusCode.OK: