Catch and log transform errors in the GrpcStreamBroadcaster

[shsms]

No description provided.

[Copilot]

Pull request overview

This PR adds error handling to the GrpcStreamBroadcaster to catch and log exceptions raised by the transform method, preventing the entire stream from failing when individual message transformations fail.

• Added try-except block around the transform call to catch exceptions and log them
• Messages that fail transformation are now skipped (using continue) so the stream continues processing subsequent messages
• Added comprehensive test coverage for transform errors
• Added @override decorators to retry strategy implementations for better type safety

Reviewed changes

Copilot reviewed 4 out of 4 changed files in this pull request and generated 4 comments.

File	Description
src/frequenz/client/base/streaming.py	Added exception handling around the transform call to catch, log, and skip messages that fail transformation
tests/streaming/test_grpc_stream_broadcaster.py	Added test case to verify transform errors are caught, logged, and don't break the stream
src/frequenz/client/base/retry.py	Added @override decorators to next_interval methods in retry strategy classes
RELEASE_NOTES.md	Documented the bug fix for transform error handling

Comments suppressed due to low confidence (1)

tests/streaming/test_grpc_stream_broadcaster.py:304

• Variable error is not used.

    def transform_err(x: int) -> str:

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.