We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b5ae9b4 commit 1157957Copy full SHA for 1157957
dapr/aio/clients/grpc/subscription.py
@@ -67,7 +67,7 @@ async def next_message(self):
67
return None
68
return SubscriptionMessage(message.event_message)
69
except AioRpcError as e:
70
- if e.code() == StatusCode.UNAVAILABLE:
+ if e.code() == StatusCode.UNAVAILABLE or e.code() == StatusCode.UNKNOWN:
71
print(
72
f'gRPC error while reading from stream: {e.details()}, '
73
f'Status Code: {e.code()}. '
0 commit comments