Specify timeout policy when constructing Timers

This is because the older constructors were deprecated by channel
v1.0.0-rc1.

Signed-off-by: Sahas Subramanian <[email protected]>

Author: shsms

src/frequenz/sdk/actor/power_distributing/_component_status/_battery_status_tracker.py

@@ -29,7 +29,7 @@
 
 # pylint: enable=no-name-in-module
 from frequenz.channels import Receiver, Sender, select, selected_from
-from frequenz.channels.timer import Timer
+from frequenz.channels.timer import SkipMissedAndDrift, Timer
 from frequenz.client.microgrid import (
     BatteryData,
     ComponentCategory,
@@ -147,11 +147,11 @@ def __init__(  # pylint: disable=too-many-arguments
 
         self._battery: _ComponentStreamStatus = _ComponentStreamStatus(
             component_id,
-            data_recv_timer=Timer.timeout(max_data_age),
+            data_recv_timer=Timer(max_data_age, SkipMissedAndDrift()),
         )
         self._inverter: _ComponentStreamStatus = _ComponentStreamStatus(
             inverter_id,
-            data_recv_timer=Timer.timeout(max_data_age),
+            data_recv_timer=Timer(max_data_age, SkipMissedAndDrift()),
         )
 
         # Select needs receivers that can be get in async way only.

src/frequenz/sdk/timeseries/_resampling.py

@@ -16,7 +16,7 @@
 from datetime import datetime, timedelta, timezone
 from typing import cast
 
-from frequenz.channels.timer import Timer, _to_microseconds
+from frequenz.channels.timer import Timer, TriggerAllMissed, _to_microseconds
 
 from .._internal._asyncio import cancel_and_await
 from ._base_types import UNIX_EPOCH, Sample
@@ -384,7 +384,7 @@ def __init__(self, config: ResamplerConfig) -> None:
         the window end is deterministic.
         """
 
-        self._timer: Timer = Timer.periodic(config.resampling_period)
+        self._timer: Timer = Timer(config.resampling_period, TriggerAllMissed())
         """The timer used to trigger the resampling windows."""
 
         # Hack to align the timer, this should be implemented in the Timer class

src/frequenz/sdk/timeseries/ev_charger_pool/_set_current_bounds.py

@@ -9,7 +9,7 @@
 from datetime import timedelta
 
 from frequenz.channels import Broadcast, Sender, select, selected_from
-from frequenz.channels.timer import Timer
+from frequenz.channels.timer import SkipMissedAndDrift, Timer
 from frequenz.client.microgrid import ComponentCategory
 
 from ..._internal._asyncio import cancel_and_await
@@ -100,7 +100,9 @@ async def _run(self) -> None:
         latest_bound: dict[int, ComponentCurrentLimit] = {}
 
         bound_chan = self._bounds_rx
-        timer = Timer.timeout(timedelta(self._repeat_interval.total_seconds()))
+        timer = Timer(
+            timedelta(self._repeat_interval.total_seconds()), SkipMissedAndDrift()
+        )
 
         async for selected in select(bound_chan, timer):
             meter = meter_data.get()