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.
1 parent dd40f55 commit 0d41be4Copy full SHA for 0d41be4
src/frequenz/client/dispatch/_client.py
@@ -270,12 +270,9 @@ def _get_stream(
270
request = StreamMicrogridDispatchesRequest(microgrid_id=int(microgrid_id))
271
broadcaster = GrpcStreamBroadcaster(
272
stream_name="StreamMicrogridDispatches",
273
- stream_method=lambda: cast(
274
- AsyncIterator[StreamMicrogridDispatchesResponse],
275
- self.stub.StreamMicrogridDispatches(
276
- request,
277
- timeout=self._stream_timeout_seconds,
278
- ),
+ stream_method=lambda: self.stub.StreamMicrogridDispatches(
+ request,
+ timeout=self._stream_timeout_seconds,
279
),
280
transform=DispatchEvent.from_protobuf,
281
retry_strategy=LinearBackoff(interval=1, limit=None),
0 commit comments