From 62298ae844c25729878241d2655bf019d7bf8a6f Mon Sep 17 00:00:00 2001
From: avollkopf <43980694+avollkopf@users.noreply.github.com>
Date: Sat, 25 Mar 2023 18:35:17 +0100
Subject: [PATCH] additional logging in mqttsensor task cancel

---
 cbpi/__init__.py                       |  2 +-
 cbpi/extension/mqtt_sensor/__init__.py | 13 ++++++++-----
 2 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/cbpi/__init__.py b/cbpi/__init__.py
index 36da73a..cf50002 100644
--- a/cbpi/__init__.py
+++ b/cbpi/__init__.py
@@ -1,3 +1,3 @@
-__version__ = "4.1.7.a10"
+__version__ = "4.1.7.a11"
 __codename__ = "Groundhog Day"
 
diff --git a/cbpi/extension/mqtt_sensor/__init__.py b/cbpi/extension/mqtt_sensor/__init__.py
index 443ce07..d7c78d3 100644
--- a/cbpi/extension/mqtt_sensor/__init__.py
+++ b/cbpi/extension/mqtt_sensor/__init__.py
@@ -126,12 +126,15 @@ class MQTTSensor(CBPiSensor):
         return dict(value=self.value)
 
     async def on_stop(self):
-        if self.mqtt_task.done() is False:
+        if not self.mqtt_task.done():
+            logging.warning("Task not done -> cancelling")
             self.mqtt_task.cancel()
-            try:
-                await self.mqtt_task
-            except asyncio.CancelledError:
-                pass
+        try:            
+            logging.warning("trying to call cancelled task")
+            await self.mqtt_task
+        except asyncio.CancelledError:
+            logging.warning("Task has been Cancelled")
+            pass
 
 
 def setup(cbpi):