Upgrade to api v0.5.0

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

Author: flora-hofmann-frequenz

RELEASE_NOTES.md

@@ -6,7 +6,7 @@
 
 ## Upgrading
 
-<!-- Here goes notes on how to upgrade from previous versions, including deprecations and what they should be replaced with -->
+* Update to use frequenz-api-reporting 0.6
 
 ## New Features
 

pyproject.toml

@@ -28,7 +28,7 @@ requires-python = ">= 3.11, < 4"
 dependencies = [
   "typing_extensions >= 4.6.1, < 5",
   "grpc-stubs == 1.53.0.5",
-  "frequenz-api-reporting >= 0.2.0, < 0.5",
+  "frequenz-api-reporting >= 0.2.0, < 0.6",
   "frequenz-client-common >= 0.2.0, < 0.3",
   "grpcio >= 1.54.2, < 2",
   "grpcio-tools >= 1.54.2, < 2",

src/frequenz/client/reporting/_client.py

@@ -16,6 +16,9 @@
     MicrogridComponentIDs as PBMicrogridComponentIDs,
 )
 from frequenz.api.reporting.v1.reporting_pb2 import IncludeOptions as PBIncludeOptions
+from frequenz.api.reporting.v1.reporting_pb2 import (
+    MetricConnections as PBMetricConnections,
+)
 from frequenz.api.reporting.v1.reporting_pb2 import (
     ReceiveMicrogridComponentsDataStreamRequest as PBReceiveMicrogridComponentsDataStreamRequest,
 )
@@ -33,7 +36,8 @@
 from google.protobuf.timestamp_pb2 import Timestamp as PBTimestamp
 
 MetricSample = namedtuple(
-    "MetricSample", ["timestamp", "microgrid_id", "component_id", "metric", "value"]
+    "MetricSample",
+    ["timestamp", "microgrid_id", "component_id", "metric", "value"],
 )
 """Type for a sample of a time series incl. metric type, microgrid and component ID
 
@@ -65,6 +69,7 @@ def is_empty(self) -> bool:
             return True
         return False
 
+    # pylint: disable=too-many-locals
     def __iter__(self) -> Iterator[MetricSample]:
         """Get generator that iterates over all values in the batch.
 
@@ -123,11 +128,8 @@ def __iter__(self) -> Iterator[MetricSample]:
                     "warning": state.warnings,
                     "error": state.errors,
                 }.items():
-                    # Skip if the category is not present
                     if not isinstance(category, Iterable):
                         continue
-                    # Each category can have multiple states
-                    # that are provided as individual samples
                     for s in category:
                         yield MetricSample(
                             timestamp=ts,
@@ -317,11 +319,17 @@ def dt2ts(dt: datetime) -> PBTimestamp:
             include_options=include_options,
         )
 
-        metrics_pb = [metric.to_proto() for metric in metrics]
+        metric_conns_pb = [
+            PBMetricConnections(
+                metric=metric.to_proto(),
+                connections=[],
+            )
+            for metric in metrics
+        ]
 
         request = PBReceiveMicrogridComponentsDataStreamRequest(
             microgrid_components=microgrid_components_pb,
-            metrics=metrics_pb,
+            metrics=metric_conns_pb,
             filter=stream_filter,
         )