From 80078c2ed4e8ef1c346b81a6487db997ae03d439 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 29 Dec 2015 15:43:27 -0800 Subject: [PATCH] Fix HeartbeatTask request_in_flight handling --- kafka/coordinator/abstract.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/coordinator/abstract.py b/kafka/coordinator/abstract.py index 1713433..10df9a5 100644 --- a/kafka/coordinator/abstract.py +++ b/kafka/coordinator/abstract.py @@ -574,7 +574,7 @@ class HeartbeatTask(object): def _handle_heartbeat_success(self, v): log.debug("Received successful heartbeat") - self.request_in_flight = False + self._request_in_flight = False self._heartbeat.received_heartbeat() ttl = self._heartbeat.ttl() self._client.schedule(self, time.time() + ttl)