Merge branch 'rc3' of github.com:elena-kolevska/python-sdk into rc3

elena-kolevska · elena-kolevska · commit 1e3adbf5a984 · 2025-02-20T22:54:45.000Z
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`	`)`