Move PowerDistributingActor to the microgrid module

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

Author: shsms

benchmarks/power_distribution/power_distributor.py

@@ -16,7 +16,8 @@
 
 from frequenz.sdk import microgrid
 from frequenz.sdk.actor import ResamplerConfig
-from frequenz.sdk.actor.power_distributing import (
+from frequenz.sdk.microgrid import connection_manager
+from frequenz.sdk.microgrid._power_distributing import (
     ComponentPoolStatus,
     Error,
     OutOfBounds,
@@ -26,7 +27,6 @@
     Result,
     Success,
 )
-from frequenz.sdk.microgrid import connection_manager
 from frequenz.sdk.timeseries._quantities import Power
 
 HOST = "microgrid.sandbox.api.frequenz.io"

…sdk/actor/power_distributing/__init__.py …icrogrid/_power_distributing/__init__.pysrc/frequenz/sdk/actor/power_distributing/__init__.py renamed to src/frequenz/sdk/microgrid/_power_distributing/__init__.py src/frequenz/sdk/actor/power_distributing/__init__.py renamed to src/frequenz/sdk/microgrid/_power_distributing/__init__.py

@@ -20,10 +20,9 @@
 )
 from typing_extensions import override
 
-from .... import microgrid
 from ...._internal._math import is_close_to_zero
-from ....microgrid import connection_manager
 from ....timeseries._quantities import Power
+from ... import connection_manager
 from .._component_pool_status_tracker import ComponentPoolStatusTracker
 from .._component_status import BatteryStatusTracker, ComponentPoolStatus
 from .._distribution_algorithm import (
@@ -617,7 +616,7 @@ async def _set_distributed_power(
             Tuple where first element is total failed power, and the second element
             set of batteries that failed.
         """
-        api = microgrid.connection_manager.get().api_client
+        api = connection_manager.get().api_client
 
         tasks = {
             inverter_id: asyncio.create_task(api.set_power(inverter_id, power))

…ributing/_component_managers/__init__.py …ributing/_component_managers/__init__.pysrc/frequenz/sdk/actor/power_distributing/_component_managers/__init__.py renamed to src/frequenz/sdk/microgrid/_power_distributing/_component_managers/__init__.py src/frequenz/sdk/actor/power_distributing/_component_managers/__init__.py renamed to src/frequenz/sdk/microgrid/_power_distributing/_component_managers/__init__.py

@@ -24,10 +24,9 @@
 )
 from typing_extensions import override
 
-from frequenz.sdk import microgrid
-
 from ....._internal._math import is_close_to_zero
 from .....timeseries import Power, Sample3Phase, Voltage
+from .... import _data_pipeline, connection_manager
 from ..._component_pool_status_tracker import ComponentPoolStatusTracker
 from ..._component_status import ComponentPoolStatus, EVChargerStatusTracker
 from ...request import Request
@@ -63,7 +62,7 @@ def __init__(
         self._ev_charger_ids = self._get_ev_charger_ids()
         self._evc_states = EvcStates()
         self._voltage_cache: LatestValueCache[Sample3Phase[Voltage]] = LatestValueCache(
-            microgrid.voltage_per_phase().new_receiver(),
+            _data_pipeline.voltage_per_phase().new_receiver(),
             unique_id=f"{type(self).__name__}«{hex(id(self))}»:voltage_cache",
         )
         self._config = EVDistributionConfig(component_ids=self._ev_charger_ids)
@@ -112,7 +111,7 @@ def _get_ev_charger_ids(self) -> collections.abc.Set[int]:
         """Return the IDs of all EV chargers present in the component graph."""
         return {
             evc.component_id
-            for evc in microgrid.connection_manager.get().component_graph.components(
+            for evc in connection_manager.get().component_graph.components(
                 component_categories={ComponentCategory.EV_CHARGER}
             )
         }
@@ -229,7 +228,7 @@ async def _run_forever(self) -> None:
 
     async def _run(self) -> None:  # pylint: disable=too-many-locals
         """Run the main event loop of the EV charger manager."""
-        api = microgrid.connection_manager.get().api_client
+        api = connection_manager.get().api_client
         ev_charger_data_rx = merge(
             *[await api.ev_charger_data(evc_id) for evc_id in self._ev_charger_ids]
         )