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):