Skip to content

Commit 7f692a6

Browse files
committed
fix: type issues
Signed-off-by: Konvalinka <[email protected]>
1 parent da62cd2 commit 7f692a6

File tree

1 file changed

+7
-5
lines changed
  • providers/openfeature-provider-flagd/src/openfeature/contrib/provider/flagd/resolvers/process/connector

1 file changed

+7
-5
lines changed

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

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -214,8 +214,12 @@ def _fetch_metadata(self) -> typing.Optional[sync_pb2.GetMetadataResponse]:
214214
return None
215215

216216
context_values_request = sync_pb2.GetMetadataRequest()
217+
context_values_response: sync_pb2.GetMetadataResponse
217218
try:
218-
return self.stub.GetMetadata(context_values_request, wait_for_ready=True)
219+
context_values_response = self.stub.GetMetadata(
220+
context_values_request, wait_for_ready=True
221+
)
222+
return context_values_response
219223
except grpc.RpcError as e:
220224
logger.debug(f"Error getting sync metadata: {e}")
221225
return None
@@ -230,9 +234,7 @@ def listen(self) -> None:
230234

231235
while self.active:
232236
try:
233-
context_values_response: typing.Optional[
234-
sync_pb2.GetMetadataResponse
235-
] = self._fetch_metadata()
237+
context_values_response = self._fetch_metadata()
236238

237239
request = sync_pb2.SyncFlagsRequest(**request_args)
238240

@@ -246,7 +248,7 @@ def listen(self) -> None:
246248
)
247249
self.flag_store.update(json.loads(flag_str))
248250

249-
context_values = None
251+
context_values = {}
250252
if flag_rsp.sync_context:
251253
context_values = MessageToDict(flag_rsp.sync_context)
252254
elif context_values_response:

0 commit comments

Comments
 (0)