We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
GrpcStreamBroadcaster
1 parent 2445ff8 commit a15045dCopy full SHA for a15045d
src/frequenz/client/base/streaming.py
@@ -88,6 +88,7 @@ def is_running(self) -> bool:
88
89
async def stop(self) -> None:
90
"""Stop the streaming helper."""
91
+ _logger.info("%s: stopping the stream", self._stream_name)
92
if self._task.done():
93
return
94
self._task.cancel()
tests/streaming/test_grpc_stream_broadcaster.py
@@ -218,6 +218,11 @@ async def test_streaming_error( # pylint: disable=too-many-arguments
218
'\tdebug_error_string = "mock debug_error_string"\n'
219
">.",
220
),
221
+ (
222
+ "frequenz.client.base.streaming",
223
+ logging.INFO,
224
+ "test_helper: stopping the stream",
225
+ ),
226
]
227
228
0 commit comments