Skip to content

Commit 95c4642

Browse files
committed
fixup: linting
Signed-off-by: Simon Schrottner <[email protected]>
1 parent 8ff06ba commit 95c4642

File tree

2 files changed

+13
-10
lines changed
  • providers/openfeature-provider-flagd/src/openfeature/contrib/provider/flagd/resolvers

2 files changed

+13
-10
lines changed

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

Lines changed: 12 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -214,7 +214,7 @@ def _create_request_args(self) -> dict:
214214

215215
return request_args
216216

217-
def _create_metadata(self) -> typing.Optional[typing.Tuple[typing.Tuple[str, str]]]:
217+
def _create_metadata(self) -> typing.Optional[tuple[tuple[str, str]]]:
218218
"""Create gRPC metadata headers for the request.
219219
220220
Returns gRPC metadata as a list of tuples containing header key-value pairs.
@@ -244,14 +244,7 @@ def _fetch_metadata(self) -> typing.Optional[sync_pb2.GetMetadataResponse]:
244244
raise e
245245

246246
def listen(self) -> None: # noqa: C901
247-
call_args: GrpcMultiCallableArgs = {"wait_for_ready": True}
248-
if self.streamline_deadline_seconds > 0:
249-
call_args["timeout"] = self.streamline_deadline_seconds
250-
251-
# Add selector via gRPC metadata header (flagd v0.11.0+ preferred approach)
252-
metadata = self._create_metadata()
253-
if metadata is not None:
254-
call_args["metadata"] = metadata
247+
call_args = self.generate_grpc_call_args()
255248

256249
request_args = self._create_request_args()
257250

@@ -299,3 +292,13 @@ def listen(self) -> None: # noqa: C901
299292
logger.exception(
300293
f"Could not parse flag data using flagd syntax: {flag_str=}"
301294
)
295+
296+
def generate_grpc_call_args(self):
297+
call_args: GrpcMultiCallableArgs = {"wait_for_ready": True}
298+
if self.streamline_deadline_seconds > 0:
299+
call_args["timeout"] = self.streamline_deadline_seconds
300+
# Add selector via gRPC metadata header (flagd v0.11.0+ preferred approach)
301+
metadata = self._create_metadata()
302+
if metadata is not None:
303+
call_args["metadata"] = metadata
304+
return call_args

providers/openfeature-provider-flagd/src/openfeature/contrib/provider/flagd/resolvers/types.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,4 +4,4 @@
44
class GrpcMultiCallableArgs(typing.TypedDict, total=False):
55
timeout: typing.Optional[float]
66
wait_for_ready: typing.Optional[bool]
7-
metadata: typing.Optional[typing.Tuple[typing.Tuple[str, str]]]
7+
metadata: typing.Optional[tuple[tuple[str, str]]]

0 commit comments

Comments
 (0)