pub/python-betterproto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Apply black formatting

Browse Source
This commit is contained in:
Nat Noordanus 2020-05-22 18:46:43 +02:00
parent 33fb83faad
commit 91f586f7d7
4 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
betterproto/__init__.py
View File

@ -1015,10 +1015,10 @@ class ServiceStub(ABC):
def __init__( def __init__(
self, self,
channel: 'Channel', channel: "Channel",
*, *,
timeout: Optional[float] = None, timeout: Optional[float] = None,
deadline: Optional['Deadline'] = None, deadline: Optional["Deadline"] = None,
metadata: Optional[_MetadataLike] = None, metadata: Optional[_MetadataLike] = None,
) -> None: ) -> None:
self.channel = channel self.channel = channel
@ -1029,7 +1029,7 @@ class ServiceStub(ABC):
def __resolve_request_kwargs( def __resolve_request_kwargs(
self, self,
timeout: Optional[float], timeout: Optional[float],
deadline: Optional['Deadline'], deadline: Optional["Deadline"],
metadata: Optional[_MetadataLike], metadata: Optional[_MetadataLike],
): ):
return { return {
@ -1045,7 +1045,7 @@ class ServiceStub(ABC):
response_type: Type[T], response_type: Type[T],
*, *,
timeout: Optional[float] = None, timeout: Optional[float] = None,
deadline: Optional['Deadline'] = None, deadline: Optional["Deadline"] = None,
metadata: Optional[_MetadataLike] = None, metadata: Optional[_MetadataLike] = None,
) -> T: ) -> T:
"""Make a unary request and return the response.""" """Make a unary request and return the response."""
@ -1068,7 +1068,7 @@ class ServiceStub(ABC):
response_type: Type[T], response_type: Type[T],
*, *,
timeout: Optional[float] = None, timeout: Optional[float] = None,
deadline: Optional['Deadline'] = None, deadline: Optional["Deadline"] = None,
metadata: Optional[_MetadataLike] = None, metadata: Optional[_MetadataLike] = None,
) -> AsyncGenerator[T, None]: ) -> AsyncGenerator[T, None]:
"""Make a unary request and return the stream response iterator.""" """Make a unary request and return the stream response iterator."""

2
betterproto/plugin.py
View File

@ -122,7 +122,7 @@ def get_py_zero(type_num: int) -> str:
def traverse(proto_file): def traverse(proto_file):
def _traverse(path, items, prefix = ''): def _traverse(path, items, prefix=""):
for i, item in enumerate(items): for i, item in enumerate(items):
# Adjust the name since we flatten the heirarchy. # Adjust the name since we flatten the heirarchy.
item.name = next_prefix = prefix + item.name item.name = next_prefix = prefix + item.name

2
betterproto/tests/test_features.py
View File

@ -256,7 +256,7 @@ def test_to_dict_default_values():
some_double: float = betterproto.double_field(2) some_double: float = betterproto.double_field(2)
some_message: TestChildMessage = betterproto.message_field(3) some_message: TestChildMessage = betterproto.message_field(3)
test = TestParentMessage().from_dict({"someInt": 0, "someDouble": 1.2,}) test = TestParentMessage().from_dict({"someInt": 0, "someDouble": 1.2})
assert test.to_dict(include_default_values=True) == { assert test.to_dict(include_default_values=True) == {
"someInt": 0, "someInt": 0,

10
betterproto/tests/test_service_stub.py
View File

@ -29,7 +29,7 @@ class ExampleService:
grpclib.const.Cardinality.UNARY_UNARY, grpclib.const.Cardinality.UNARY_UNARY,
DoThingRequest, DoThingRequest,
DoThingResponse, DoThingResponse,
), )
} }
@ -94,7 +94,9 @@ async def test_service_call_lower_level_with_overrides():
) as channel: ) as channel:
stub = ExampleServiceStub(channel, deadline=deadline, metadata=metadata) stub = ExampleServiceStub(channel, deadline=deadline, metadata=metadata)
response = await stub._unary_unary( response = await stub._unary_unary(
"/service.ExampleService/DoThing", DoThingRequest(ITERATIONS), DoThingResponse, "/service.ExampleService/DoThing",
DoThingRequest(ITERATIONS),
DoThingResponse,
deadline=kwarg_deadline, deadline=kwarg_deadline,
metadata=kwarg_metadata, metadata=kwarg_metadata,
) )
@ -116,7 +118,9 @@ async def test_service_call_lower_level_with_overrides():
) as channel: ) as channel:
stub = ExampleServiceStub(channel, deadline=deadline, metadata=metadata) stub = ExampleServiceStub(channel, deadline=deadline, metadata=metadata)
response = await stub._unary_unary( response = await stub._unary_unary(
"/service.ExampleService/DoThing", DoThingRequest(ITERATIONS), DoThingResponse, "/service.ExampleService/DoThing",
DoThingRequest(ITERATIONS),
DoThingResponse,
timeout=kwarg_timeout, timeout=kwarg_timeout,
metadata=kwarg_metadata, metadata=kwarg_metadata,
) )