From 3fe4bacf02c6b19b821e49ef6590c39e9682e4cd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Guillaume=20Desv=C3=A9?= Date: Tue, 10 Oct 2017 16:14:11 +0200 Subject: [PATCH] Fix missing positional argument on 'cancel_tasks' --- hbmqtt/client.py | 4 ++-- hbmqtt/mqtt/puback.py | 1 - 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/hbmqtt/client.py b/hbmqtt/client.py index 253a5a0..e0b98b3 100644 --- a/hbmqtt/client.py +++ b/hbmqtt/client.py @@ -430,7 +430,7 @@ class MQTTClient: @asyncio.coroutine def handle_connection_close(self): - def cancel_tasks(self): + def cancel_tasks(): while self.client_tasks: task = self.client_tasks.popleft() if not task.done(): @@ -456,7 +456,7 @@ class MQTTClient: yield from self.reconnect() except ConnectException: # Cancel client pending tasks - cancel_tasks(self) + cancel_tasks() else: # Cancel client pending tasks cancel_tasks() diff --git a/hbmqtt/mqtt/puback.py b/hbmqtt/mqtt/puback.py index 7bbd065..12e72cd 100644 --- a/hbmqtt/mqtt/puback.py +++ b/hbmqtt/mqtt/puback.py @@ -6,7 +6,6 @@ from hbmqtt.errors import HBMQTTException class PubackPacket(MQTTPacket): - VARIABLE_HEADER = PacketIdVariableHeader PAYLOAD = None