diff --git a/sonora/asgi.py b/sonora/asgi.py index c18a06b..93012cc 100644 --- a/sonora/asgi.py +++ b/sonora/asgi.py @@ -191,7 +191,7 @@ async def _do_unary_response( self, rpc_method, receive, send, wrap_message, context, coroutine ): headers = context._response_headers - + if coroutine is None: message = None else: diff --git a/sonora/client.py b/sonora/client.py index 375ac79..fc0b52c 100644 --- a/sonora/client.py +++ b/sonora/client.py @@ -54,7 +54,10 @@ def __init__(self, session, url, path, request_serializer, request_deserializer) self._path = path self._rpc_url = urljoin(url, path) - self._metadata = [("x-user-agent", "grpc-web-python/0.1"), ('content-type', 'application/grpc-web+proto')] + self._metadata = [ + ("x-user-agent", "grpc-web-python/0.1"), + ("content-type", "application/grpc-web+proto"), + ] self._serializer = request_serializer self._deserializer = request_deserializer diff --git a/tests/conftest.py b/tests/conftest.py index dca1459..2f29874 100644 --- a/tests/conftest.py +++ b/tests/conftest.py @@ -117,7 +117,7 @@ async def HelloMetadata(self, request, context): for key, value in context.invocation_metadata() ) - await context.set_trailing_metadata( + context.set_trailing_metadata( (f"trailing-{key}", repr(value)) for key, value in context.invocation_metadata() ) @@ -139,7 +139,7 @@ async def HelloStreamMetadata(self, request, context): for c in value: yield helloworld_pb2.HelloReply(message=c) - await context.set_trailing_metadata( + context.set_trailing_metadata( (f"trailing-{key}", repr(value)) for key, value in context.invocation_metadata() )