From 7df48bdf088ad12f8482eb7b2c3c470dc86db528 Mon Sep 17 00:00:00 2001 From: avollkopf <43980694+avollkopf@users.noreply.github.com> Date: Mon, 27 Mar 2023 22:31:47 +0200 Subject: [PATCH] missing varable in mqttsensor --- cbpi/__init__.py | 2 +- cbpi/extension/mqtt_sensor/__init__.py | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/cbpi/__init__.py b/cbpi/__init__.py index 2c56255..497a4df 100644 --- a/cbpi/__init__.py +++ b/cbpi/__init__.py @@ -1,3 +1,3 @@ -__version__ = "4.1.7.rc2" +__version__ = "4.1.7.rc3" __codename__ = "Groundhog Day" diff --git a/cbpi/extension/mqtt_sensor/__init__.py b/cbpi/extension/mqtt_sensor/__init__.py index bec2799..b6c8d09 100644 --- a/cbpi/extension/mqtt_sensor/__init__.py +++ b/cbpi/extension/mqtt_sensor/__init__.py @@ -129,6 +129,7 @@ class MQTTSensor(CBPiSensor): return dict(value=self.value) async def on_stop(self): + was_cancelled=False if not self.mqtt_task.done(): logging.info("Task not done -> cancelling") was_cancelled = self.mqtt_task.cancel()