From 92436c0ec02a450b509a3d80defd0606ba43b609 Mon Sep 17 00:00:00 2001 From: Chris Lane Date: Wed, 13 Apr 2016 19:54:55 -0700 Subject: to squelch the __del issue --- kafka/client_async.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'kafka/client_async.py') diff --git a/kafka/client_async.py b/kafka/client_async.py index 2eb86cf..b72e98a 100644 --- 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 -- cgit v1.2.1