openstack/deb-python-kafka
Code Issues Proposed changes

Fix HeartbeatTask request_in_flight handling

Browse Source
This commit is contained in:
Dana Powers
2015-12-29 15:43:27 -08:00
parent 70d2f2630d
commit 80078c2ed4
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/coordinator/abstract.py
View File

@@ -574,7 +574,7 @@ class HeartbeatTask(object):
def _handle_heartbeat_success(self, v): def _handle_heartbeat_success(self, v):
log.debug("Received successful heartbeat") log.debug("Received successful heartbeat")
self.request_in_flight = False self._request_in_flight = False
self._heartbeat.received_heartbeat() self._heartbeat.received_heartbeat()
ttl = self._heartbeat.ttl() ttl = self._heartbeat.ttl()
self._client.schedule(self, time.time() + ttl) self._client.schedule(self, time.time() + ttl)