Replace the internal microgrid API client with frequenz-client-microgrid

RELEASE_NOTES.md

@@ -6,12 +6,12 @@
 
 ## Upgrading
 
-<!-- Here goes notes on how to upgrade from previous versions, including deprecations and what they should be replaced with -->
+- The SDK is now using the microgrid API client from [`frequenz-client-microgrid`](https://github.com/frequenz-floss/frequenz-client-microgrid-python/). You should update your code if you are using the microgrid API client directly.
 
 ## New Features
 
 <!-- Here goes the main new features and examples or instructions on how to use them -->
 
 ## Bug Fixes
 
-<!-- Here goes notable bug fixes that are worth a special mention or explanation -->
+- A bug was fixed where the grid fuse was not created properly and would end up with a `max_current` with type `float` instead of `Current`.

benchmarks/power_distribution/power_distributor.py

@@ -12,6 +12,7 @@
 from typing import Any
 
 from frequenz.channels import Broadcast
+from frequenz.client.microgrid import Component, ComponentCategory
 
 from frequenz.sdk import microgrid
 from frequenz.sdk.actor import ResamplerConfig
@@ -26,7 +27,6 @@
     Success,
 )
 from frequenz.sdk.microgrid import connection_manager
-from frequenz.sdk.microgrid.component import Component, ComponentCategory
 from frequenz.sdk.timeseries._quantities import Power
 
 HOST = "microgrid.sandbox.api.frequenz.io"

benchmarks/timeseries/benchmark_datasourcing.py

@@ -17,14 +17,14 @@
 from typing import Any
 
 from frequenz.channels import Broadcast, Receiver, ReceiverStoppedError
+from frequenz.client.microgrid import ComponentMetricId
 
 from frequenz.sdk import microgrid
 from frequenz.sdk.actor import (
     ChannelRegistry,
     ComponentMetricRequest,
     DataSourcingActor,
 )
-from frequenz.sdk.microgrid.component import ComponentMetricId
 
 try:
     from tests.timeseries.mock_microgrid import MockMicrogrid

pyproject.toml

@@ -31,6 +31,7 @@ dependencies = [
   # changing the version
   # (plugins.mkdocstrings.handlers.python.import)
   "frequenz-channels == 1.0.0b2",
+  "frequenz-client-microgrid >= 0.1.2, < 0.2.0",
   "google-api-python-client >= 2.71, < 3",
   "grpcio >= 1.54.2, < 2",
   "grpcio-tools >= 1.54.2, < 2",

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

@@ -6,7 +6,7 @@
 from dataclasses import dataclass
 from datetime import datetime
 
-from ...microgrid.component._component import ComponentMetricId
+from frequenz.client.microgrid import ComponentMetricId
 
 
 @dataclass

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

@@ -9,16 +9,16 @@
 from typing import Any
 
 from frequenz.channels import Receiver, Sender
-
-from ...microgrid import connection_manager
-from ...microgrid.component import (
+from frequenz.client.microgrid import (
     BatteryData,
     ComponentCategory,
     ComponentMetricId,
     EVChargerData,
     InverterData,
     MeterData,
 )
+
+from ...microgrid import connection_manager
 from ...timeseries import Sample
 from ...timeseries._quantities import Quantity
 from .._channel_registry import ChannelRegistry

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

@@ -12,9 +12,9 @@
 
 from frequenz.channels import Receiver, Sender
 from frequenz.channels.util import SkipMissedAndDrift, Timer, select, selected_from
+from frequenz.client.microgrid import ComponentCategory
 from typing_extensions import override
 
-from ...microgrid.component import ComponentCategory
 from ...timeseries._base_types import SystemBounds
 from .._actor import Actor
 from .._channel_registry import ChannelRegistry

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

@@ -12,13 +12,13 @@
 
 import grpc
 from frequenz.channels import Receiver, Sender
+from frequenz.client.microgrid import BatteryData, ComponentCategory, InverterData
 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 ....microgrid.component import BatteryData, ComponentCategory, InverterData
 from ....timeseries._quantities import Power
 from .._component_pool_status_tracker import ComponentPoolStatusTracker
 from .._component_status import BatteryStatusTracker, ComponentPoolStatus

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

@@ -30,15 +30,15 @@
 # pylint: enable=no-name-in-module
 from frequenz.channels import Receiver, Sender
 from frequenz.channels.util import Timer, select, selected_from
-from typing_extensions import override
-
-from ....microgrid import connection_manager
-from ....microgrid.component import (
+from frequenz.client.microgrid import (
     BatteryData,
     ComponentCategory,
     ComponentData,
     InverterData,
 )
+from typing_extensions import override
+
+from ....microgrid import connection_manager
 from ..._background_service import BackgroundService
 from ._blocking_status import BlockingStatus
 from ._component_status import (

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

@@ -8,8 +8,9 @@
 from dataclasses import dataclass
 from typing import NamedTuple, Sequence
 
+from frequenz.client.microgrid import BatteryData, InverterData
+
 from ...._internal._math import is_close_to_zero
-from ....microgrid.component import BatteryData, InverterData
 from ..result import PowerBounds
 
 _logger = logging.getLogger(__name__)

src/frequenz/sdk/microgrid/__init__.py

@@ -122,7 +122,7 @@
 """  # noqa: D205, D400
 
 from ..actor import ResamplerConfig
-from . import _data_pipeline, client, component, connection_manager, metadata
+from . import _data_pipeline, connection_manager
 from ._data_pipeline import (
     battery_pool,
     consumer,
@@ -149,15 +149,12 @@ async def initialize(host: str, port: int, resampler_config: ResamplerConfig) ->
 
 __all__ = [
     "initialize",
-    "client",
-    "component",
     "consumer",
     "battery_pool",
     "ev_charger_pool",
     "grid",
     "frequency",
     "logical_meter",
-    "metadata",
     "producer",
     "voltage",
 ]

src/frequenz/sdk/microgrid/_power_wrapper.py

@@ -13,7 +13,7 @@
 # pylint seems to think this is a cyclic import, but it is not.
 #
 # pylint: disable=cyclic-import
-from .component import ComponentCategory
+from frequenz.client.microgrid import ComponentCategory
 
 # A number of imports had to be done inside functions where they are used, to break
 # import cycles.