to squelch the __del issue

2016-04-13 19:54:55 -07:00
parent 0c94b83a2d
commit 92436c0ec0
1 changed files with 4 additions and 2 deletions
--- a/kafka/client_async.py
+++ b/kafka/client_async.py
@@ -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'):
+            os.close(self._wake_r)
+        if hasattr(self, '_wake_w'):
+            os.close(self._wake_w)

    def _bootstrap(self, hosts):
        # Exponential backoff if bootstrap fails