Fix stream reconnecting (#151)

Marenz · web-flow · commit 207b4e96a1fc · 2025-04-29T10:32:04.000Z
diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md
@@ -7,3 +7,4 @@
 ## Bug Fixes
 
 * Fix that `dispatch-cli stream` would try to print an event as dispatch, causing an exception.
+* Fix that `stream()` would not reconnect and just closes the channel upon disconnection.
diff --git a/src/frequenz/client/dispatch/_client.py b/src/frequenz/client/dispatch/_client.py
@@ -241,7 +241,7 @@ def _get_stream(
                     ),
                 ),
                 transform=DispatchEvent.from_protobuf,
-                retry_strategy=LinearBackoff(interval=1, limit=0),
+                retry_strategy=LinearBackoff(interval=1, limit=None),
             )
             self._streams[microgrid_id] = broadcaster
 

Original file line number	Diff line number	Diff line change
`@@ -7,3 +7,4 @@`
`7`	`7`	`## Bug Fixes`
`8`	`8`
`9`	`9`	* Fix that `dispatch-cli stream` would try to print an event as dispatch, causing an exception.
	`10`	+* Fix that `stream()` would not reconnect and just closes the channel upon disconnection.
Original file line number	Diff line number	Diff line change
`@@ -241,7 +241,7 @@ def _get_stream(`
`241`	`241`	`),`
`242`	`242`	`),`
`243`	`243`	`transform=DispatchEvent.from_protobuf,`
`244`		`- retry_strategy=LinearBackoff(interval=1, limit=0),`
	`244`	`+ retry_strategy=LinearBackoff(interval=1, limit=None),`
`245`	`245`	`)`
`246`	`246`	`self._streams[microgrid_id] = broadcaster`
`247`	`247`