Skip to content

Commit 720748b

Browse files
committed
Enable resend_latest on resampled stream channels
Signed-off-by: Sahas Subramanian <[email protected]>
1 parent 187cf0e commit 720748b

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

src/frequenz/sdk/timeseries/formulas/_resampled_stream_fetcher.py

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -60,8 +60,12 @@ async def fetch_stream(
6060
self._metric,
6161
None,
6262
)
63-
await self._resampler_subscription_sender.send(request)
6463

65-
return self._channel_registry.get_or_create(
64+
chan = self._channel_registry.get_or_create(
6665
Sample[Quantity], request.get_channel_name()
67-
).new_receiver()
66+
)
67+
chan.resend_latest = True
68+
69+
await self._resampler_subscription_sender.send(request)
70+
71+
return chan.new_receiver()

0 commit comments

Comments
 (0)