Skip to content

Commit 39ea40b

Browse files
committed
chore(flagd): Minimally refactor GrpcWatcher.listen() to pass ruff complexity pre-commit
Signed-off-by: Maks Osowski <[email protected]>
1 parent 67e7a3b commit 39ea40b

File tree

1 file changed

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

1 file changed

+10
-5
lines changed

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

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -163,17 +163,22 @@ def shutdown(self) -> None:
163163
self.active = False
164164
self.channel.close()
165165

166+
def _create_request_args(self) -> dict:
167+
request_args = {}
168+
if self.selector is not None:
169+
request_args["selector"] = self.selector
170+
if self.provider_id is not None:
171+
request_args["provider_id"] = self.provider_id
172+
173+
return request_args
174+
166175
def listen(self) -> None:
167176
call_args = (
168177
{"timeout": self.streamline_deadline_seconds}
169178
if self.streamline_deadline_seconds > 0
170179
else {}
171180
)
172-
request_args = {}
173-
if self.selector is not None:
174-
request_args["selector"] = self.selector
175-
if self.provider_id is not None:
176-
request_args["provider_id"] = self.provider_id
181+
request_args = self._create_request_args()
177182

178183
while self.active:
179184
try:

0 commit comments

Comments
 (0)