Skip to content

Commit efbd542

Browse files
committed
Ignore minor mypy errors
Signed-off-by: Sergio Herrera <627709+seherv@users.noreply.github.com>
1 parent ead2e85 commit efbd542

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

dapr/clients/exceptions.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ def __init__(self, err: RpcError):
164164
self._err_message = err.details()
165165
self._details = StatusDetails()
166166

167-
self._grpc_status = rpc_status.from_call(err)
167+
self._grpc_status = rpc_status.from_call(err) # type: ignore[arg-type]
168168
self._parse_details()
169169

170170
def _parse_details(self):

dapr/clients/grpc/subscription.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ def outgoing_request_iterator():
6363
self._stream = self._stub.SubscribeTopicEventsAlpha1(outgoing_request_iterator())
6464
self._set_stream_active()
6565
try:
66-
next(self._stream) # discard the initial message
66+
next(self._stream) # type: ignore[arg-type] # discard the initial message
6767
except Exception as e:
6868
raise Exception(f'Error while initializing stream: {e}')
6969

@@ -84,7 +84,7 @@ def next_message(self):
8484

8585
try:
8686
# Read the next message from the stream directly
87-
message = next(self._stream)
87+
message = next(self._stream) # type: ignore[call-overload]
8888
return SubscriptionMessage(message.event_message)
8989
except RpcError as e:
9090
# If Dapr can't be reached, wait until it's ready and reconnect the stream.

0 commit comments

Comments
 (0)