Switch to the LatestValueCache from the channels package

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

Author: shsms

src/frequenz/sdk/actor/power_distributing/_component_managers/_battery_manager.py

@@ -10,7 +10,7 @@
 import typing
 from datetime import timedelta
 
-from frequenz.channels import Receiver, Sender
+from frequenz.channels import LatestValueCache, Receiver, Sender
 from frequenz.client.microgrid import (
     BatteryData,
     ClientError,
@@ -21,7 +21,6 @@
 from typing_extensions import override
 
 from .... import microgrid
-from ...._internal._channels import LatestValueCache
 from ...._internal._math import is_close_to_zero
 from ....microgrid import connection_manager
 from ....timeseries._quantities import Power

src/frequenz/sdk/actor/power_distributing/_component_managers/_ev_charger_manager/_ev_charger_manager.py

@@ -8,7 +8,14 @@
 import logging
 from datetime import datetime, timedelta, timezone
 
-from frequenz.channels import Broadcast, Sender, merge, select, selected_from
+from frequenz.channels import (
+    Broadcast,
+    LatestValueCache,
+    Sender,
+    merge,
+    select,
+    selected_from,
+)
 from frequenz.client.microgrid import (
     ApiClient,
     ClientError,
@@ -19,7 +26,6 @@
 
 from frequenz.sdk import microgrid
 
-from ....._internal._channels import LatestValueCache
 from ....._internal._math import is_close_to_zero
 from .....timeseries import Power, Sample3Phase, Voltage
 from ..._component_pool_status_tracker import ComponentPoolStatusTracker

src/frequenz/sdk/actor/power_distributing/_component_managers/_pv_inverter_manager/_pv_inverter_manager.py

@@ -8,7 +8,7 @@
 import logging
 from datetime import timedelta
 
-from frequenz.channels import Broadcast, Sender
+from frequenz.channels import Broadcast, LatestValueCache, Sender
 from frequenz.client.microgrid import (
     ClientError,
     ComponentCategory,
@@ -17,7 +17,6 @@
 )
 from typing_extensions import override
 
-from ....._internal._channels import LatestValueCache
 from ....._internal._math import is_close_to_zero
 from .....microgrid import connection_manager
 from .....timeseries import Power

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

@@ -8,12 +8,11 @@
 from dataclasses import dataclass
 from datetime import timedelta
 
-from frequenz.channels import Broadcast, Sender, select, selected_from
+from frequenz.channels import Broadcast, LatestValueCache, Sender, select, selected_from
 from frequenz.channels.timer import SkipMissedAndDrift, Timer
 from frequenz.client.microgrid import ComponentCategory, MeterData
 
 from ..._internal._asyncio import cancel_and_await
-from ..._internal._channels import LatestValueCache
 from ...microgrid import connection_manager
 
 _logger = logging.getLogger(__name__)

tests/timeseries/_battery_pool/test_battery_pool_control_methods.py

@@ -10,11 +10,10 @@
 from unittest.mock import AsyncMock, MagicMock
 
 import pytest
-from frequenz.channels import Sender
+from frequenz.channels import LatestValueCache, Sender
 from pytest_mock import MockerFixture
 
 from frequenz.sdk import microgrid, timeseries
-from frequenz.sdk._internal._channels import LatestValueCache
 from frequenz.sdk.actor import ResamplerConfig, power_distributing
 from frequenz.sdk.actor.power_distributing import ComponentPoolStatus
 from frequenz.sdk.actor.power_distributing._component_pool_status_tracker import (