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.
2 parents e5f49b9 + aa3062c commit a0045f9Copy full SHA for a0045f9
src/frequenz/sdk/timeseries/_moving_window.py
@@ -72,15 +72,15 @@ async def run() -> None:
72
send_task = asyncio.create_task(send_mock_data(resampled_data_sender))
73
74
window = MovingWindow(
75
- size=timedelta(minutes=5),
+ size=timedelta(seconds=5),
76
resampled_data_recv=resampled_data_receiver,
77
input_sampling_period=timedelta(seconds=1),
78
)
79
80
time_start = datetime.now(tz=timezone.utc)
81
- time_end = time_start + timedelta(minutes=5)
+ time_end = time_start + timedelta(seconds=5)
82
83
- # ... wait for 5 minutes until the buffer is filled
+ # ... wait for 5 seconds until the buffer is filled
84
await asyncio.sleep(5)
85
86
# return an numpy array from the window
0 commit comments