From f65aac0be311751c1e3e94577c3566473d450ae7 Mon Sep 17 00:00:00 2001 From: Flora Date: Mon, 9 Jun 2025 10:19:05 +0200 Subject: [PATCH] Take out async for sensors Signed-off-by: Flora --- RELEASE_NOTES.md | 2 +- src/frequenz/client/reporting/_client.py | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md index f80f12e..adb9fa1 100644 --- a/RELEASE_NOTES.md +++ b/RELEASE_NOTES.md @@ -14,4 +14,4 @@ ## Bug Fixes - +* Take out 'async' from 'receive_microgrid_sensors_data' and 'receive_single_sensor_data'. diff --git a/src/frequenz/client/reporting/_client.py b/src/frequenz/client/reporting/_client.py index 3d2d677..5c19037 100644 --- a/src/frequenz/client/reporting/_client.py +++ b/src/frequenz/client/reporting/_client.py @@ -316,7 +316,7 @@ async def stream_method() -> ( return self._components_data_streams[stream_key].new_receiver() # pylint: disable=too-many-arguments - async def receive_single_sensor_data( + def receive_single_sensor_data( self, *, microgrid_id: int, @@ -341,7 +341,7 @@ async def receive_single_sensor_data( Returns: A receiver of `MetricSample`s. """ - receiver = await self._receive_microgrid_sensors_data_batch( + receiver = self._receive_microgrid_sensors_data_batch( microgrid_sensors=[(microgrid_id, [sensor_id])], metrics=[metrics] if isinstance(metrics, Metric) else metrics, start_time=start_time, @@ -352,7 +352,7 @@ async def receive_single_sensor_data( return BatchUnrollReceiver(receiver) # pylint: disable=too-many-arguments - async def receive_microgrid_sensors_data( + def receive_microgrid_sensors_data( self, *, microgrid_sensors: list[tuple[int, list[int]]], @@ -376,7 +376,7 @@ async def receive_microgrid_sensors_data( Returns: A receiver of `MetricSample`s. """ - receiver = await self._receive_microgrid_sensors_data_batch( + receiver = self._receive_microgrid_sensors_data_batch( microgrid_sensors=microgrid_sensors, metrics=[metrics] if isinstance(metrics, Metric) else metrics, start_time=start_time, @@ -388,7 +388,7 @@ async def receive_microgrid_sensors_data( # pylint: disable=too-many-arguments # pylint: disable=too-many-locals - async def _receive_microgrid_sensors_data_batch( + def _receive_microgrid_sensors_data_batch( self, *, microgrid_sensors: list[tuple[int, list[int]]],