Skip to content

Commit 7847a88

Browse files
committed
Use the new external microgrid API client
Signed-off-by: Leandro Lucarella <[email protected]>
1 parent 75e2e41 commit 7847a88

File tree

56 files changed

+166
-136
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

56 files changed

+166
-136
lines changed

benchmarks/power_distribution/power_distributor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
from typing import Any
1313

1414
from frequenz.channels import Broadcast
15+
from frequenz.client.microgrid import Component, ComponentCategory
1516

1617
from frequenz.sdk import microgrid
1718
from frequenz.sdk.actor import ResamplerConfig
@@ -26,7 +27,6 @@
2627
Success,
2728
)
2829
from frequenz.sdk.microgrid import connection_manager
29-
from frequenz.sdk.microgrid.component import Component, ComponentCategory
3030
from frequenz.sdk.timeseries._quantities import Power
3131

3232
HOST = "microgrid.sandbox.api.frequenz.io"

benchmarks/timeseries/benchmark_datasourcing.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,14 @@
1717
from typing import Any
1818

1919
from frequenz.channels import Broadcast, Receiver, ReceiverStoppedError
20+
from frequenz.client.microgrid import ComponentMetricId
2021

2122
from frequenz.sdk import microgrid
2223
from frequenz.sdk.actor import (
2324
ChannelRegistry,
2425
ComponentMetricRequest,
2526
DataSourcingActor,
2627
)
27-
from frequenz.sdk.microgrid.component import ComponentMetricId
2828

2929
try:
3030
from tests.timeseries.mock_microgrid import MockMicrogrid

src/frequenz/sdk/actor/_data_sourcing/_component_metric_request.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
from dataclasses import dataclass
77
from datetime import datetime
88

9-
from ...microgrid.component._component import ComponentMetricId
9+
from frequenz.client.microgrid import ComponentMetricId
1010

1111

1212
@dataclass

src/frequenz/sdk/actor/_data_sourcing/microgrid_api_source.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,16 +9,16 @@
99
from typing import Any
1010

1111
from frequenz.channels import Receiver, Sender
12-
13-
from ...microgrid import connection_manager
14-
from ...microgrid.component import (
12+
from frequenz.client.microgrid import (
1513
BatteryData,
1614
ComponentCategory,
1715
ComponentMetricId,
1816
EVChargerData,
1917
InverterData,
2018
MeterData,
2119
)
20+
21+
from ...microgrid import connection_manager
2222
from ...timeseries import Sample
2323
from ...timeseries._quantities import Quantity
2424
from .._channel_registry import ChannelRegistry

src/frequenz/sdk/actor/_power_managing/_power_managing_actor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,9 @@
1212

1313
from frequenz.channels import Receiver, Sender
1414
from frequenz.channels.util import SkipMissedAndDrift, Timer, select, selected_from
15+
from frequenz.client.microgrid import ComponentCategory
1516
from typing_extensions import override
1617

17-
from ...microgrid.component import ComponentCategory
1818
from ...timeseries._base_types import SystemBounds
1919
from .._actor import Actor
2020
from .._channel_registry import ChannelRegistry

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,13 +12,13 @@
1212

1313
import grpc
1414
from frequenz.channels import Receiver, Sender
15+
from frequenz.client.microgrid import BatteryData, ComponentCategory, InverterData
1516
from typing_extensions import override
1617

1718
from .... import microgrid
1819
from ...._internal._channels import LatestValueCache
1920
from ...._internal._math import is_close_to_zero
2021
from ....microgrid import connection_manager
21-
from ....microgrid.component import BatteryData, ComponentCategory, InverterData
2222
from ....timeseries._quantities import Power
2323
from .._component_pool_status_tracker import ComponentPoolStatusTracker
2424
from .._component_status import BatteryStatusTracker, ComponentPoolStatus

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -30,15 +30,15 @@
3030
# pylint: enable=no-name-in-module
3131
from frequenz.channels import Receiver, Sender
3232
from frequenz.channels.util import Timer, select, selected_from
33-
from typing_extensions import override
34-
35-
from ....microgrid import connection_manager
36-
from ....microgrid.component import (
33+
from frequenz.client.microgrid import (
3734
BatteryData,
3835
ComponentCategory,
3936
ComponentData,
4037
InverterData,
4138
)
39+
from typing_extensions import override
40+
41+
from ....microgrid import connection_manager
4242
from ..._background_service import BackgroundService
4343
from ._blocking_status import BlockingStatus
4444
from ._component_status import (

src/frequenz/sdk/actor/power_distributing/_distribution_algorithm/_battery_distribution_algorithm.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,9 @@
88
from dataclasses import dataclass
99
from typing import NamedTuple, Sequence
1010

11+
from frequenz.client.microgrid import BatteryData, InverterData
12+
1113
from ...._internal._math import is_close_to_zero
12-
from ....microgrid.component import BatteryData, InverterData
1314
from ..result import PowerBounds
1415

1516
_logger = logging.getLogger(__name__)

src/frequenz/sdk/microgrid/_power_wrapper.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
# pylint seems to think this is a cyclic import, but it is not.
1414
#
1515
# pylint: disable=cyclic-import
16-
from .component import ComponentCategory
16+
from frequenz.client.microgrid import ComponentCategory
1717

1818
# A number of imports had to be done inside functions where they are used, to break
1919
# import cycles.

src/frequenz/sdk/microgrid/component_graph.py

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,9 +28,13 @@
2828
from dataclasses import asdict
2929

3030
import networkx as nx
31-
32-
from .client import Connection, MicrogridApiClient
33-
from .component import Component, ComponentCategory, InverterType
31+
from frequenz.client.microgrid import (
32+
ApiClient,
33+
Component,
34+
ComponentCategory,
35+
Connection,
36+
InverterType,
37+
)
3438

3539
_logger = logging.getLogger(__name__)
3640

@@ -536,7 +540,7 @@ def refresh_from(
536540

537541
async def refresh_from_api(
538542
self,
539-
api: MicrogridApiClient,
543+
api: ApiClient,
540544
correct_errors: Callable[["_MicrogridComponentGraph"], None] | None = None,
541545
) -> None:
542546
"""Refresh the contents of a component graph from the remote API.

0 commit comments

Comments
 (0)