to squelch the __del issue

chlanejayasinha · chlanejayasinha · commit 92436c0ec02a · 2016-04-13T19:54:55.000-07:00
diff --git a/kafka/client_async.py b/kafka/client_async.py
@@ -133,8 +133,10 @@ def __init__(self, **configs):
         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
