Switch to reporting API v1alpha10

This includes the major update to common API v1alpha8.

Signed-off-by: cwasicki <[email protected]>

Author: cwasicki

src/frequenz/client/reporting/_client.py

@@ -8,42 +8,44 @@
 from typing import cast
 
 # pylint: disable=no-name-in-module
-from frequenz.api.common.v1.microgrid.microgrid_pb2 import (
-    MicrogridComponentIDs as PBMicrogridComponentIDs,
+from frequenz.api.common.v1alpha8.microgrid.microgrid_pb2 import (
+    MicrogridElectricalComponentIDs as PBMicrogridComponentIDs,
 )
-from frequenz.api.common.v1.microgrid.microgrid_pb2 import (
+from frequenz.api.common.v1alpha8.microgrid.microgrid_pb2 import (
     MicrogridSensorIDs as PBMicrogridSensorIDs,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     AggregationConfig as PBAggregationConfig,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import FilterOption as PBFilterOption
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
+    FilterOption as PBFilterOption,
+)
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     MetricConnections as PBMetricConnections,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ReceiveAggregatedMicrogridComponentsDataStreamRequest as PBAggregatedStreamRequest,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ReceiveAggregatedMicrogridComponentsDataStreamResponse as PBAggregatedStreamResponse,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ReceiveMicrogridComponentsDataStreamRequest as PBReceiveMicrogridComponentsDataStreamRequest,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ReceiveMicrogridComponentsDataStreamResponse as PBReceiveMicrogridComponentsDataStreamResponse,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ReceiveMicrogridSensorsDataStreamRequest as PBReceiveMicrogridSensorsDataStreamRequest,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ReceiveMicrogridSensorsDataStreamResponse as PBReceiveMicrogridSensorsDataStreamResponse,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ResamplingOptions as PBResamplingOptions,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import TimeFilter as PBTimeFilter
-from frequenz.api.reporting.v1.reporting_pb2_grpc import ReportingStub
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import TimeFilter as PBTimeFilter
+from frequenz.api.reporting.v1alpha10.reporting_pb2_grpc import ReportingStub
 from frequenz.channels import Receiver
 from frequenz.client.base.channel import ChannelOptions
 from frequenz.client.base.client import BaseApiClient
@@ -250,7 +252,7 @@ def _receive_microgrid_components_data_batch(
             or not self._components_data_streams[stream_key].is_running
         ):
             microgrid_components_pb = [
-                PBMicrogridComponentIDs(microgrid_id=mid, component_ids=cids)
+                PBMicrogridComponentIDs(microgrid_id=mid, electrical_component_ids=cids)
                 for mid, cids in microgrid_components
             ]
 

src/frequenz/client/reporting/_types.py

@@ -9,13 +9,13 @@
 from typing import Any, NamedTuple
 
 # pylint: disable=no-name-in-module
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ReceiveAggregatedMicrogridComponentsDataStreamResponse as PBAggregatedStreamResponse,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ReceiveMicrogridComponentsDataStreamResponse as PBReceiveMicrogridComponentsDataStreamResponse,
 )
-from frequenz.api.reporting.v1.reporting_pb2 import (
+from frequenz.api.reporting.v1alpha10.reporting_pb2 import (
     ReceiveMicrogridSensorsDataStreamResponse as PBReceiveMicrogridSensorsDataStreamResponse,
 )
 

tests/test_client_reporting.py

@@ -5,7 +5,7 @@
 from unittest.mock import MagicMock, patch
 
 import pytest
-from frequenz.api.reporting.v1.reporting_pb2_grpc import ReportingStub
+from frequenz.api.reporting.v1alpha10.reporting_pb2_grpc import ReportingStub
 from frequenz.client.base.channel import ChannelOptions
 from frequenz.client.base.client import BaseApiClient