From e78ccc4273e2757ab1fa9a3cbd4c360446fc8983 Mon Sep 17 00:00:00 2001 From: "Mathias L. Baumann" Date: Mon, 28 Apr 2025 15:30:38 +0200 Subject: [PATCH 1/2] Fix: When a stream disconnects, it will not reconnect Signed-off-by: Mathias L. Baumann --- src/frequenz/client/dispatch/_client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 From e7ac2d2b0a40e268c77d323d93376b026a79f970 Mon Sep 17 00:00:00 2001 From: "Mathias L. Baumann" Date: Mon, 28 Apr 2025 15:41:41 +0200 Subject: [PATCH 2/2] Update release notes Signed-off-by: Mathias L. Baumann --- RELEASE_NOTES.md | 1 + 1 file changed, 1 insertion(+) 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.