Skip to content

Commit ad031dc

Browse files
Take out async for sensors (#189)
Think we forgot to take out 'async' when refactoring in #177
2 parents b6accfa + f65aac0 commit ad031dc

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

RELEASE_NOTES.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,4 +14,4 @@
1414

1515
## Bug Fixes
1616

17-
<!-- Here goes notable bug fixes that are worth a special mention or explanation -->
17+
* Take out 'async' from 'receive_microgrid_sensors_data' and 'receive_single_sensor_data'.

src/frequenz/client/reporting/_client.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -316,7 +316,7 @@ async def stream_method() -> (
316316
return self._components_data_streams[stream_key].new_receiver()
317317

318318
# pylint: disable=too-many-arguments
319-
async def receive_single_sensor_data(
319+
def receive_single_sensor_data(
320320
self,
321321
*,
322322
microgrid_id: int,
@@ -341,7 +341,7 @@ async def receive_single_sensor_data(
341341
Returns:
342342
A receiver of `MetricSample`s.
343343
"""
344-
receiver = await self._receive_microgrid_sensors_data_batch(
344+
receiver = self._receive_microgrid_sensors_data_batch(
345345
microgrid_sensors=[(microgrid_id, [sensor_id])],
346346
metrics=[metrics] if isinstance(metrics, Metric) else metrics,
347347
start_time=start_time,
@@ -352,7 +352,7 @@ async def receive_single_sensor_data(
352352
return BatchUnrollReceiver(receiver)
353353

354354
# pylint: disable=too-many-arguments
355-
async def receive_microgrid_sensors_data(
355+
def receive_microgrid_sensors_data(
356356
self,
357357
*,
358358
microgrid_sensors: list[tuple[int, list[int]]],
@@ -376,7 +376,7 @@ async def receive_microgrid_sensors_data(
376376
Returns:
377377
A receiver of `MetricSample`s.
378378
"""
379-
receiver = await self._receive_microgrid_sensors_data_batch(
379+
receiver = self._receive_microgrid_sensors_data_batch(
380380
microgrid_sensors=microgrid_sensors,
381381
metrics=[metrics] if isinstance(metrics, Metric) else metrics,
382382
start_time=start_time,
@@ -388,7 +388,7 @@ async def receive_microgrid_sensors_data(
388388

389389
# pylint: disable=too-many-arguments
390390
# pylint: disable=too-many-locals
391-
async def _receive_microgrid_sensors_data_batch(
391+
def _receive_microgrid_sensors_data_batch(
392392
self,
393393
*,
394394
microgrid_sensors: list[tuple[int, list[int]]],

0 commit comments

Comments
 (0)