diff --git a/dapr/aio/clients/grpc/client.py b/dapr/aio/clients/grpc/client.py index 765eee34..f9f53498 100644 --- a/dapr/aio/clients/grpc/client.py +++ b/dapr/aio/clients/grpc/client.py @@ -215,7 +215,7 @@ async def __aexit__(self, exc_type, exc_value, traceback) -> None: @staticmethod def _get_http_extension( - http_verb: str, http_querystring: Optional[MetadataTuple] = None + http_verb: str, http_querystring: Optional[MetadataTuple] = None ) -> common_v1.HTTPExtension: # type: ignore verb = common_v1.HTTPExtension.Verb.Value(http_verb) # type: ignore http_ext = common_v1.HTTPExtension(verb=verb) diff --git a/dapr/clients/grpc/_response.py b/dapr/clients/grpc/_response.py index 51e27d8e..2beb1a2f 100644 --- a/dapr/clients/grpc/_response.py +++ b/dapr/clients/grpc/_response.py @@ -648,7 +648,9 @@ class ConfigurationResponse(DaprResponse): - items (Mapping[Text, ConfigurationItem]): state's data. """ - def __init__(self, items: Mapping[Text, common_v1.ConfigurationItem], headers: MetadataTuple = ()): + def __init__( + self, items: Mapping[Text, common_v1.ConfigurationItem], headers: MetadataTuple = () + ): """Initializes ConfigurationResponse from :obj:`runtime_v1.GetConfigurationResponse`. Args: @@ -704,7 +706,9 @@ def _read_subscribe_config( handler: Callable[[Text, ConfigurationResponse], None], ): try: - responses: List[api_v1.SubscribeConfigurationResponse] = stub.SubscribeConfigurationAlpha1(req) + responses: List[ + api_v1.SubscribeConfigurationResponse + ] = stub.SubscribeConfigurationAlpha1(req) isFirst = True for response in responses: if isFirst: diff --git a/dapr/clients/grpc/client.py b/dapr/clients/grpc/client.py index 3388ef13..64a26408 100644 --- a/dapr/clients/grpc/client.py +++ b/dapr/clients/grpc/client.py @@ -213,7 +213,7 @@ def __exit__(self, exc_type, exc_value, traceback) -> None: @staticmethod def _get_http_extension( - http_verb: str, http_querystring: Optional[MetadataTuple] = None + http_verb: str, http_querystring: Optional[MetadataTuple] = None ) -> common_v1.HTTPExtension: # type: ignore verb = common_v1.HTTPExtension.Verb.Value(http_verb) # type: ignore http_ext = common_v1.HTTPExtension(verb=verb)