diff options
Diffstat (limited to 'kafka/client_async.py')
| -rw-r--r-- | kafka/client_async.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 29cb8c0..2e78e3b 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -852,8 +852,8 @@ class KafkaClient(object): def wakeup(self): with self._wake_lock: try: - assert self._wake_w.send(b'x') == 1 - except (AssertionError, socket.error): + self._wake_w.sendall(b'x') + except socket.error: log.warning('Unable to send to wakeup socket!') def _clear_wake_fd(self): |