Skip to content

Commit 327db6a

Browse files
committed
Remove unused timer
Now the `_wait_for_next_resampling_period()` method is used to trigger the next resampling. Signed-off-by: Leandro Lucarella <[email protected]>
1 parent d806bf4 commit 327db6a

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

src/frequenz/sdk/timeseries/_resampling.py

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,6 @@
1515
from datetime import datetime, timedelta, timezone
1616
from typing import AsyncIterator, Callable, Coroutine, Optional, Sequence
1717

18-
from frequenz.channels.util import Timer
19-
2018
from .._internal.asyncio import cancel_and_await
2119
from . import Sample
2220

@@ -350,9 +348,6 @@ def __init__(self, config: ResamplerConfig) -> None:
350348
self._resamplers: dict[Source, _StreamingHelper] = {}
351349
"""A mapping between sources and the streaming helper handling that source."""
352350

353-
self._timer: Timer = Timer(config.resampling_period_s)
354-
"""The timer to trigger the next resampling."""
355-
356351
self._window_end: datetime = datetime.now(timezone.utc) + timedelta(
357352
seconds=self._config.resampling_period_s
358353
)

0 commit comments

Comments
 (0)