Skip to content

Commit c75821f

Browse files
committed
fix: tests
Signed-off-by: Konvalinka <[email protected]>
1 parent 6d6ebb8 commit c75821f

File tree

1 file changed

+3
-2
lines changed
  • providers/openfeature-provider-flagd/src/openfeature/contrib/provider/flagd/resolvers/process/connector

1 file changed

+3
-2
lines changed

providers/openfeature-provider-flagd/src/openfeature/contrib/provider/flagd/resolvers/process/connector/grpc_watcher.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -215,11 +215,12 @@ def _fetch_metadata(self) -> dict:
215215
return {}
216216

217217
context_values_request = sync_pb2.GetMetadataRequest()
218+
context_values_response: sync_pb2.GetMetadataResponse
218219
try:
219220
context_values_response = self.stub.GetMetadata(
220221
context_values_request, wait_for_ready=True
221222
)
222-
return MessageToDict(context_values_response)
223+
return MessageToDict(context_values_response)["metadata"]
223224
except grpc.RpcError as e:
224225
if e.code() == StatusCode.UNIMPLEMENTED:
225226
logger.debug("Metadata endpoint disabled")
@@ -237,7 +238,7 @@ def listen(self) -> None:
237238

238239
while self.active:
239240
try:
240-
context_values = self._fetch_metadata()["metadata"]
241+
context_values = self._fetch_metadata()
241242

242243
request = sync_pb2.SyncFlagsRequest(**request_args)
243244

0 commit comments

Comments
 (0)