Retry streaming subscription on status UNKNOWN as well (dapr#783)

elena-kolevska · elena-kolevska · commit de4744654421 · 2025-03-06T13:50:48.000Z
Signed-off-by: Elena Kolevska &lt;elena@kolevska.com&gt;
diff --git a/dapr/clients/grpc/subscription.py b/dapr/clients/grpc/subscription.py
@@ -84,7 +84,7 @@ def next_message(self):
             return SubscriptionMessage(message.event_message)
         except RpcError as e:
             # If Dapr can't be reached, wait until it's ready and reconnect the stream
-            if e.code() == StatusCode.UNAVAILABLE:
+            if e.code() == StatusCode.UNAVAILABLE or e.code() == StatusCode.UNKNOWN:
                 print(
                     f'gRPC error while reading from stream: {e.details()}, Status Code: {e.code()}'
                 )

Original file line number	Diff line number	Diff line change
`@@ -84,7 +84,7 @@ def next_message(self):`
`84`	`84`	`return SubscriptionMessage(message.event_message)`
`85`	`85`	`except RpcError as e:`
`86`	`86`	`# If Dapr can't be reached, wait until it's ready and reconnect the stream`
`87`		`- if e.code() == StatusCode.UNAVAILABLE:`
	`87`	`+ if e.code() == StatusCode.UNAVAILABLE or e.code() == StatusCode.UNKNOWN:`
`88`	`88`	`print(`
`89`	`89`	`f'gRPC error while reading from stream: {e.details()}, Status Code: {e.code()}'`
`90`	`90`	`)`