Skip to content

Commit bfa6e20

Browse files
bgedikdpkp
authored andcommitted
Remove assertion with side effect (#1348)
1 parent 8f82017 commit bfa6e20

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kafka/client_async.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -852,8 +852,8 @@ def check_version(self, node_id=None, timeout=2, strict=False):
852852
def wakeup(self):
853853
with self._wake_lock:
854854
try:
855-
assert self._wake_w.send(b'x') == 1
856-
except (AssertionError, socket.error):
855+
self._wake_w.sendall(b'x')
856+
except socket.error:
857857
log.warning('Unable to send to wakeup socket!')
858858

859859
def _clear_wake_fd(self):

0 commit comments

Comments
 (0)