openstack/deb-python-kafka
Code Issues Proposed changes

Remove unused cluster._version private attribute

Browse Source
This commit is contained in:
Dana Powers
2016-02-15 16:15:50 -08:00
parent ca7cd0dd11
commit 89b4c2ff37
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
kafka/cluster.py
View File

@@ -26,7 +26,6 @@ class ClusterMetadata(object):
self._partitions = {} self._partitions = {}
self._broker_partitions = collections.defaultdict(set) self._broker_partitions = collections.defaultdict(set)
self._groups = {} self._groups = {}
self._version = 0
self._last_refresh_ms = 0 self._last_refresh_ms = 0
self._last_successful_refresh_ms = 0 self._last_successful_refresh_ms = 0
self._need_update = False self._need_update = False
@@ -158,12 +157,10 @@ class ClusterMetadata(object):
self._future.success(self) self._future.success(self)
self._future = None self._future = None
self._need_update = False self._need_update = False
self._version += 1
now = time.time() * 1000 now = time.time() * 1000
self._last_refresh_ms = now self._last_refresh_ms = now
self._last_successful_refresh_ms = now self._last_successful_refresh_ms = now
log.debug("Updated cluster metadata version %d to %s", log.debug("Updated cluster metadata to %s", self)
self._version, self)
for listener in self._listeners: for listener in self._listeners:
listener(self) listener(self)