Skip to content

Commit b47602a

Browse files
committed
Move resampling actor to frequenz.sdk.actor
More precisely, from: frequenz.sdk.data_ingestion.resampling.component_metrics_resampling_actor to: frequenz.sdk.actor.resampling Signed-off-by: Leandro Lucarella <[email protected]>
1 parent 5862456 commit b47602a

File tree

3 files changed

+8
-10
lines changed

3 files changed

+8
-10
lines changed

examples/sdk_resampling_example.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,9 +13,7 @@
1313

1414
from frequenz.sdk.actor import ChannelRegistry
1515
from frequenz.sdk.actor.data_sourcing import DataSourcingActor
16-
from frequenz.sdk.data_ingestion.resampling.component_metrics_resampling_actor import (
17-
ComponentMetricsResamplingActor,
18-
)
16+
from frequenz.sdk.actor.resampling import ComponentMetricsResamplingActor
1917
from frequenz.sdk.data_pipeline import ComponentMetricId, ComponentMetricRequest
2018
from frequenz.sdk.microgrid import ComponentCategory, microgrid_api
2119

src/frequenz/sdk/data_ingestion/resampling/component_metrics_resampling_actor.py renamed to src/frequenz/sdk/actor/resampling.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,12 @@
1515

1616
from frequenz.channels import MergeNamed, Receiver, Select, Sender, Timer
1717

18-
from ...actor import ChannelRegistry, actor
19-
from ...data_pipeline import ComponentMetricRequest, Sample
20-
from .component_metric_group_resampler import ComponentMetricGroupResampler
21-
from .component_metric_resampler import ResamplingFunction
18+
from ..data_ingestion.resampling.component_metric_group_resampler import (
19+
ComponentMetricGroupResampler,
20+
)
21+
from ..data_ingestion.resampling.component_metric_resampler import ResamplingFunction
22+
from ..data_pipeline import ComponentMetricRequest, Sample
23+
from . import ChannelRegistry, actor
2224

2325
logger = logging.Logger(__name__)
2426

tests/actor/test_component_metrics_resampling_actor.py renamed to tests/actor/test_resampling.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,9 +21,7 @@
2121

2222
from frequenz.sdk.actor import ChannelRegistry
2323
from frequenz.sdk.actor.data_sourcing import DataSourcingActor
24-
from frequenz.sdk.data_ingestion.resampling.component_metrics_resampling_actor import (
25-
ComponentMetricsResamplingActor,
26-
)
24+
from frequenz.sdk.actor.resampling import ComponentMetricsResamplingActor
2725
from frequenz.sdk.data_pipeline import ComponentMetricId, ComponentMetricRequest
2826
from frequenz.sdk.microgrid import microgrid_api
2927
from tests.test_microgrid import mock_api

0 commit comments

Comments
 (0)