Renaming to allow for api-reporting update

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

Author: flora-hofmann-frequenz

src/frequenz/client/reporting/_client.py

@@ -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,