Move the resampling actor to the microgrid module

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

Author: shsms

src/frequenz/sdk/actor/__init__.py

@@ -600,15 +600,13 @@ async def main() -> None:  # (6)!
 from ._actor import Actor
 from ._background_service import BackgroundService
 from ._data_sourcing import ComponentMetricId, ComponentMetricRequest, DataSourcingActor
-from ._resampling import ComponentMetricsResamplingActor
 from ._run_utils import run
 
 __all__ = [
     "Actor",
     "BackgroundService",
     "ComponentMetricId",
     "ComponentMetricRequest",
-    "ComponentMetricsResamplingActor",
     "DataSourcingActor",
     "ResamplerConfig",
     "run",

src/frequenz/sdk/microgrid/_data_pipeline.py

@@ -470,7 +470,7 @@ def _resampling_request_sender(self) -> Sender[ComponentMetricRequest]:
         Returns:
             A Sender for sending requests to the resampling actor.
         """
-        from ..actor import ComponentMetricsResamplingActor
+        from ._resampling import ComponentMetricsResamplingActor
 
         if self._resampling_actor is None:
             channel: Broadcast[ComponentMetricRequest] = Broadcast(

src/frequenz/sdk/actor/_resampling.py src/frequenz/sdk/microgrid/_resampling.pysrc/frequenz/sdk/actor/_resampling.py renamed to src/frequenz/sdk/microgrid/_resampling.py

@@ -12,11 +12,11 @@
 
 from .._internal._asyncio import cancel_and_await
 from .._internal._channels import ChannelRegistry
+from ..actor import Actor
+from ..actor._data_sourcing import ComponentMetricRequest
 from ..timeseries import Sample
 from ..timeseries._quantities import Quantity
 from ..timeseries._resampling import Resampler, ResamplerConfig, ResamplingError
-from ._actor import Actor
-from ._data_sourcing import ComponentMetricRequest
 
 _logger = logging.getLogger(__name__)
 

tests/actor/test_resampling.py

@@ -13,12 +13,9 @@
 from frequenz.client.microgrid import ComponentMetricId
 
 from frequenz.sdk._internal._channels import ChannelRegistry
-from frequenz.sdk.actor import (
-    ComponentMetricRequest,
-    ComponentMetricsResamplingActor,
-    ResamplerConfig,
-)
-from frequenz.sdk.timeseries import Sample
+from frequenz.sdk.actor import ComponentMetricRequest
+from frequenz.sdk.microgrid._resampling import ComponentMetricsResamplingActor
+from frequenz.sdk.timeseries import ResamplerConfig, Sample
 from frequenz.sdk.timeseries._quantities import Quantity