Lidi Zheng 5 éve
szülő
commit
413d29218e

+ 3 - 5
src/python/grpcio/grpc/experimental/aio/_call.py

@@ -359,11 +359,9 @@ class UnaryStreamCall(Call, _base_call.UnaryStreamCall):
         serialized_request = _common.serialize(self._request,
                                                self._request_serializer)
         try:
-            await self._cython_call.unary_stream(
-                serialized_request,
-                self._set_initial_metadata,
-                self._set_status
-            )
+            await self._cython_call.unary_stream(serialized_request,
+                                                 self._set_initial_metadata,
+                                                 self._set_status)
         except asyncio.CancelledError:
             if self._code != grpc.StatusCode.CANCELLED:
                 self.cancel()

+ 1 - 1
src/python/grpcio_tests/tests_aio/unit/call_test.py

@@ -33,7 +33,7 @@ _LOCAL_CANCEL_DETAILS_EXPECTATION = 'Locally cancelled by application!'
 _RESPONSE_INTERVAL_US = test_constants.SHORT_TIMEOUT * 1000 * 1000
 _UNREACHABLE_TARGET = '0.1:1111'
 
-_INFINITE_INTERVAL_US = 2**31-1
+_INFINITE_INTERVAL_US = 2**31 - 1
 
 
 class TestUnaryUnaryCall(AioTestBase):