Check that _misc_task is not None before trying to cancel it. #39

empicano · Feb 24, 2021 · 3307297 · 3307297
1 parent f603b70
commit 3307297
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/asyncio_mqtt/client.py b/asyncio_mqtt/client.py
@@ -304,8 +304,9 @@ def cb():
 
     def _on_socket_close(self, client, userdata, sock):
         self._loop.remove_reader(sock.fileno())
-        with suppress(asyncio.CancelledError):
-            self._misc_task.cancel()
+        if self._misc_task is not None:
+            with suppress(asyncio.CancelledError):
+                self._misc_task.cancel()
 
     def _on_socket_register_write(self, client, userdata, sock):
         def cb():