diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md index eab08419..a3dabed6 100644 --- 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 index c777bba1..a775e10f 100644 --- 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