style: apply ruff formatting

Author: nanomad

src/publisher/mqtt_publisher.py

@@ -261,7 +261,12 @@ async def __handle_imported_energy(self, topic: str, payload: str) -> None:
             )
 
     def __publish(
-        self, topic: str, payload: WirePayload | None, *, retain: bool = True, qos: int = 0
+        self,
+        topic: str,
+        payload: WirePayload | None,
+        *,
+        retain: bool = True,
+        qos: int = 0,
     ) -> None:
         LOG.debug("Publishing to MQTT topic %s with payload %s", topic, payload)
         loop = asyncio.get_running_loop()

src/status_publisher/charge/chrg_mgmt_data.py

@@ -104,18 +104,18 @@ def publish(self, charge_mgmt_data: ChrgMgmtData) -> ChrgMgmtDataProcessingResul
         self._transform_and_publish(
             topic=mqtt_topics.BMS_CHARGE_STATUS,
             value=charge_mgmt_data.bms_charging_status,
-            transform=lambda x: f"UNKNOWN {charge_mgmt_data.bmsChrgSts}"
-            if x is None
-            else x.name,
+            transform=lambda x: (
+                f"UNKNOWN {charge_mgmt_data.bmsChrgSts}" if x is None else x.name
+            ),
         )
 
         self._transform_and_publish(
             topic=mqtt_topics.DRIVETRAIN_CHARGING_STOP_REASON,
             value=charge_mgmt_data.charging_stop_reason,
             validator=lambda x: x != ChargingStopReason.NO_REASON,
-            transform=lambda x: f"UNKNOWN {charge_mgmt_data.bmsChrgSpRsn}"
-            if x is None
-            else x.name,
+            transform=lambda x: (
+                f"UNKNOWN {charge_mgmt_data.bmsChrgSpRsn}" if x is None else x.name
+            ),
         )
 
         self._publish(
@@ -153,9 +153,9 @@ def publish(self, charge_mgmt_data: ChrgMgmtData) -> ChrgMgmtDataProcessingResul
             topic=mqtt_topics.DRIVETRAIN_BATTERY_HEATING_STOP_REASON,
             value=charge_mgmt_data.heating_stop_reason,
             validator=lambda x: x != HeatingStopReason.NO_REASON,
-            transform=lambda x: f"UNKNOWN ({charge_mgmt_data.bmsPTCHeatResp})"
-            if x is None
-            else x.name,
+            transform=lambda x: (
+                f"UNKNOWN ({charge_mgmt_data.bmsPTCHeatResp})" if x is None else x.name
+            ),
         )
 
         self._transform_and_publish(

tests/test_mqtt_publisher.py

@@ -104,9 +104,7 @@ async def on_charger_connection_state_changed(
 
     async def _call_and_flush(self, fn: Any, *args: Any, **kwargs: Any) -> AsyncMock:
         mock = AsyncMock()
-        with patch.object(
-            self.mqtt_client, "_MqttPublisher__async_publish", mock
-        ):
+        with patch.object(self.mqtt_client, "_MqttPublisher__async_publish", mock):
             self.mqtt_client._MqttPublisher__connected.set()  # type: ignore[attr-defined]
             fn(*args, **kwargs)
             await asyncio.sleep(0)
@@ -153,9 +151,7 @@ async def test_publish_float_forwards_retain_false(self) -> None:
         m.assert_called_once_with("saic/foo", 1.5, retain=False, qos=0)
 
     async def test_publish_json_default_is_retained(self) -> None:
-        m = await self._call_and_flush(
-            self.mqtt_client.publish_json, "foo", {"a": 1}
-        )
+        m = await self._call_and_flush(self.mqtt_client.publish_json, "foo", {"a": 1})
         m.assert_called_once()
         args, kwargs = m.call_args
         assert args[0] == "saic/foo"