Skip to content

Commit 8057734

Browse files
committed
[MovingWindow] Don't filter out None values from resampler
The resampler sends `None` values when there is no source data. In this case, the values need to be sent to the buffer, so that it can update its gaps immediately, instead of waiting until when data is finally available. Signed-off-by: Sahas Subramanian <[email protected]>
1 parent 5057e0a commit 8057734

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/frequenz/sdk/timeseries/_moving_window.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -343,8 +343,7 @@ def _configure_resampler(self) -> None:
343343
assert self._resampler is not None
344344

345345
async def sink_buffer(sample: Sample[Quantity]) -> None:
346-
if sample.value is not None:
347-
self._buffer.update(sample)
346+
self._buffer.update(sample)
348347

349348
resampler_channel = Broadcast[Sample[Quantity]](name="average")
350349
self._resampler_sender = resampler_channel.new_sender()

0 commit comments

Comments
 (0)