diff --git a/src/python/grpcio/grpc/experimental/aio/_channel.py b/src/python/grpcio/grpc/experimental/aio/_channel.py index 531ec49df34..13e7f922a2a 100644 --- a/src/python/grpcio/grpc/experimental/aio/_channel.py +++ b/src/python/grpcio/grpc/experimental/aio/_channel.py @@ -123,7 +123,7 @@ class UnaryUnaryMultiCallable(_BaseMultiCallable): request: Any, *, timeout: Optional[float] = None, - metadata: Optional[MetadataType] = None, + metadata: Optional[MetadataType] = _IMMUTABLE_EMPTY_TUPLE, credentials: Optional[grpc.CallCredentials] = None, wait_for_ready: Optional[bool] = None, compression: Optional[grpc.Compression] = None @@ -151,9 +151,6 @@ class UnaryUnaryMultiCallable(_BaseMultiCallable): raised RpcError will also be a Call for the RPC affording the RPC's metadata, status code, and details. """ - if metadata is None: - metadata = _IMMUTABLE_EMPTY_TUPLE - if compression: metadata = _compression.augment_metadata(metadata, compression) @@ -181,7 +178,7 @@ class UnaryStreamMultiCallable(_BaseMultiCallable): request: Any, *, timeout: Optional[float] = None, - metadata: Optional[MetadataType] = None, + metadata: Optional[MetadataType] = _IMMUTABLE_EMPTY_TUPLE, credentials: Optional[grpc.CallCredentials] = None, wait_for_ready: Optional[bool] = None, compression: Optional[grpc.Compression] = None @@ -204,9 +201,6 @@ class UnaryStreamMultiCallable(_BaseMultiCallable): Returns: A Call object instance which is an awaitable object. """ - if metadata is None: - metadata = _IMMUTABLE_EMPTY_TUPLE - if compression: metadata = _compression.augment_metadata(metadata, compression) @@ -226,7 +220,7 @@ class StreamUnaryMultiCallable(_BaseMultiCallable): def __call__(self, request_async_iterator: Optional[AsyncIterable[Any]] = None, timeout: Optional[float] = None, - metadata: Optional[MetadataType] = None, + metadata: Optional[MetadataType] = _IMMUTABLE_EMPTY_TUPLE, credentials: Optional[grpc.CallCredentials] = None, wait_for_ready: Optional[bool] = None, compression: Optional[grpc.Compression] = None @@ -254,9 +248,6 @@ class StreamUnaryMultiCallable(_BaseMultiCallable): raised RpcError will also be a Call for the RPC affording the RPC's metadata, status code, and details. """ - if metadata is None: - metadata = _IMMUTABLE_EMPTY_TUPLE - if compression: metadata = _compression.augment_metadata(metadata, compression) @@ -276,7 +267,7 @@ class StreamStreamMultiCallable(_BaseMultiCallable): def __call__(self, request_async_iterator: Optional[AsyncIterable[Any]] = None, timeout: Optional[float] = None, - metadata: Optional[MetadataType] = None, + metadata: Optional[MetadataType] = _IMMUTABLE_EMPTY_TUPLE, credentials: Optional[grpc.CallCredentials] = None, wait_for_ready: Optional[bool] = None, compression: Optional[grpc.Compression] = None @@ -304,9 +295,6 @@ class StreamStreamMultiCallable(_BaseMultiCallable): raised RpcError will also be a Call for the RPC affording the RPC's metadata, status code, and details. """ - if metadata is None: - metadata = _IMMUTABLE_EMPTY_TUPLE - if compression: metadata = _compression.augment_metadata(metadata, compression) diff --git a/src/python/grpcio/grpc/experimental/aio/_server.py b/src/python/grpcio/grpc/experimental/aio/_server.py index 9c501f2fc29..53762beaeaf 100644 --- a/src/python/grpcio/grpc/experimental/aio/_server.py +++ b/src/python/grpcio/grpc/experimental/aio/_server.py @@ -179,7 +179,8 @@ def server(migration_thread_pool: Optional[Executor] = None, indicate no limit. compression: An element of grpc.compression, e.g. grpc.compression.Gzip. This compression algorithm will be used for the - lifetime of the server unless overridden. This is an EXPERIMENTAL option. + lifetime of the server unless overridden by set_compression. This is an + EXPERIMENTAL option. Returns: A Server object.