From f80f64b0861053be7752a200d2ea6e131cf8ae34 Mon Sep 17 00:00:00 2001 From: Stijn van Houwelingen Date: Thu, 19 Feb 2026 15:47:16 +0100 Subject: [PATCH 1/3] fix: fix CEM get_message function using fix for Pydantic 1.0 Signed-off-by: Stijn van Houwelingen --- src/flexmeasures_client/s2/cem.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/src/flexmeasures_client/s2/cem.py b/src/flexmeasures_client/s2/cem.py index b13f85af..1cf9ab58 100644 --- a/src/flexmeasures_client/s2/cem.py +++ b/src/flexmeasures_client/s2/cem.py @@ -235,13 +235,7 @@ async def get_message(self) -> str: """ message = await self._sending_queue.get() - await asyncio.sleep(0.3) - - # Pending for pydantic V2 to implement model.model_dump(mode="json") in - # PR #1409 (https://github.com/pydantic/pydantic/issues/1409) - message = json.loads(message.json()) - - return message + return message.model_dump(mode="json") async def activate_control_type( self, control_type: ControlType From 0aba5ca9907ce758464717617151f31b16735a7a Mon Sep 17 00:00:00 2001 From: "F.N. Claessen" Date: Thu, 19 Feb 2026 20:58:00 +0100 Subject: [PATCH 2/3] fix: remove obsolete import Signed-off-by: F.N. Claessen --- src/flexmeasures_client/s2/cem.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/flexmeasures_client/s2/cem.py b/src/flexmeasures_client/s2/cem.py index 3656c8e7..27409e25 100644 --- a/src/flexmeasures_client/s2/cem.py +++ b/src/flexmeasures_client/s2/cem.py @@ -1,6 +1,5 @@ from __future__ import annotations -import asyncio import json import logging import math From 8ea5b7051a1f9a46c4d8797ff375ee74f5e895cb Mon Sep 17 00:00:00 2001 From: "F.N. Claessen" Date: Thu, 19 Feb 2026 21:00:47 +0100 Subject: [PATCH 3/3] style: silence flake8-blind-except Signed-off-by: F.N. Claessen --- src/flexmeasures_client/s2/cem.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/flexmeasures_client/s2/cem.py b/src/flexmeasures_client/s2/cem.py index 27409e25..6e9b7d86 100644 --- a/src/flexmeasures_client/s2/cem.py +++ b/src/flexmeasures_client/s2/cem.py @@ -382,7 +382,7 @@ async def handle_power_measurement(self, message: PowerMeasurement): values=[avg_value], unit=get_commodity_unit(commodity_quantity), ) - except Exception as e: + except Exception as e: # noqa: B902 - intentional safety net self._logger.warning( f"POSTing power measurement failed with error: {e}" )