Renaming to allow for api-reporting update (#205)

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 frequenz-api-reporting v0.8.0
 
 ## 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.6",
-  "frequenz-api-reporting >= 0.7.0, < 0.8",
+  "frequenz-api-reporting >= 0.8.0, < 0.9",
   "frequenz-client-common >= 0.3.0, < 0.4",
   "grpcio >=1.70.0, < 2",
   "protobuf >= 5.29.3, < 7",

src/frequenz/client/reporting/_client.py

@@ -260,8 +260,8 @@ def dt2ts(dt: datetime) -> PBTimestamp:
                 return ts
 
             time_filter = PBTimeFilter(
-                start=dt2ts(start_time) if start_time else None,
-                end=dt2ts(end_time) if end_time else None,
+                start_time=dt2ts(start_time) if start_time else None,
+                end_time=dt2ts(end_time) if end_time else None,
             )
 
             incl_states = (
@@ -450,8 +450,8 @@ def dt2ts(dt: datetime) -> PBTimestamp:
                 return ts
 
             time_filter = PBTimeFilter(
-                start=dt2ts(start_time) if start_time else None,
-                end=dt2ts(end_time) if end_time else None,
+                start_time=dt2ts(start_time) if start_time else None,
+                end_time=dt2ts(end_time) if end_time else None,
             )
 
             incl_states = (
@@ -566,8 +566,8 @@ def dt2ts(dt: datetime) -> PBTimestamp:
                 return ts
 
             time_filter = PBTimeFilter(
-                start=dt2ts(start_time) if start_time else None,
-                end=dt2ts(end_time) if end_time else None,
+                start_time=dt2ts(start_time) if start_time else None,
+                end_time=dt2ts(end_time) if end_time else None,
             )
 
             stream_filter = PBAggregatedStreamRequest.AggregationStreamFilter(

src/frequenz/client/reporting/_types.py

@@ -92,7 +92,7 @@ def __iter__(self) -> Iterator[MetricSample]:
         for item in items:
             cid = getattr(item, self.id_attr)
             for sample in getattr(item, "metric_samples", []):
-                ts = sample.sampled_at.ToDatetime().replace(tzinfo=timezone.utc)
+                ts = sample.sample_time.ToDatetime().replace(tzinfo=timezone.utc)
                 met = Metric.from_proto(sample.metric).name
 
                 # Handle simple_metric
@@ -127,7 +127,7 @@ def __iter__(self) -> Iterator[MetricSample]:
                             )
 
             for state in getattr(item, "states", []):
-                ts = state.sampled_at.ToDatetime().replace(tzinfo=timezone.utc)
+                ts = state.sample_time.ToDatetime().replace(tzinfo=timezone.utc)
                 for category, category_items in {
                     "state": getattr(state, "states", []),
                     "warning": getattr(state, "warnings", []),
@@ -177,7 +177,7 @@ class AggregatedMetric:
     def sample(self) -> MetricSample:
         """Return the aggregated metric sample."""
         return MetricSample(
-            timestamp=self._data_pb.sample.sampled_at.ToDatetime().replace(
+            timestamp=self._data_pb.sample.sample_time.ToDatetime().replace(
                 tzinfo=timezone.utc
             ),
             microgrid_id=self._data_pb.aggregation_config.microgrid_id,