openstack/deb-python-kafka
Code Issues Proposed changes

Merge pull request #649 from jayalane/master

Browse Source 
to squelch the __del issue
This commit is contained in:
Dana Powers
2016-04-24 08:27:22 -07:00
parent cf679ae387 86130cbbab
commit 56ba6075ac
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
kafka/client_async.py
View File

@@ -133,8 +133,10 @@ class KafkaClient(object):
self._selector.register(self._wake_r, selectors.EVENT_READ)
def __del__(self):
self._wake_r.close()
self._wake_w.close()
if hasattr(self, '_wake_r'):
self._wake_r.close()
if hasattr(self, '_wake_w'):
self._wake_w.close()
def _bootstrap(self, hosts):
# Exponential backoff if bootstrap fails