Skip to content

Commit 128bcdc

Browse files
committed
you are not my type haha
Signed-off-by: Bernd Verst <[email protected]>
1 parent 3e40e5c commit 128bcdc

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

dapr/aio/clients/grpc/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1085,7 +1085,7 @@ async def get_configuration(
10851085
store_name=store_name, keys=keys, metadata=config_metadata
10861086
)
10871087
call = self._stub.GetConfiguration(req)
1088-
response = await call
1088+
response: api_v1.GetConfigurationResponse = await call
10891089
return ConfigurationResponse(items=response.items, headers=await call.initial_metadata())
10901090

10911091
async def subscribe_configuration(

dapr/clients/grpc/_response.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
Generator,
3434
TypeVar,
3535
Generic,
36+
Mapping,
3637
)
3738

3839
from google.protobuf.any_pb2 import Any as GrpcAny
@@ -647,7 +648,7 @@ class ConfigurationResponse(DaprResponse):
647648
- items (Mapping[Text, ConfigurationItem]): state's data.
648649
"""
649650

650-
def __init__(self, items: Dict[Text, common_v1.ConfigurationItem], headers: MetadataTuple = ()):
651+
def __init__(self, items: Mapping[Text, common_v1.ConfigurationItem], headers: MetadataTuple = ()):
651652
"""Initializes ConfigurationResponse from :obj:`runtime_v1.GetConfigurationResponse`.
652653
653654
Args:
@@ -659,7 +660,7 @@ def __init__(self, items: Dict[Text, common_v1.ConfigurationItem], headers: Meta
659660
k: Text
660661
v: common_v1.ConfigurationItem
661662
for k, v in items.items():
662-
self._items[k] = ConfigurationItem(v.value, v.version, v.metadata)
663+
self._items[k] = ConfigurationItem(v.value, v.version, dict(v.metadata))
663664

664665
@property
665666
def items(self) -> Dict[Text, ConfigurationItem]:

0 commit comments

Comments
 (0)