Skip to content

Commit 02fadd3

Browse files
committed
drop unused key_selector assignment
1 parent c90386b commit 02fadd3

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
@@ -268,9 +268,9 @@ def _conn_state_change(self, node_id, sock, conn):
268268
if node_id not in self._connecting:
269269
self._connecting.add(node_id)
270270
try:
271-
key_selector = self._selector.register(sock, selectors.EVENT_WRITE)
271+
self._selector.register(sock, selectors.EVENT_WRITE)
272272
except KeyError:
273-
key_selector = self._selector.modify(sock, selectors.EVENT_WRITE)
273+
self._selector.modify(sock, selectors.EVENT_WRITE)
274274

275275
if self.cluster.is_bootstrap(node_id):
276276
self._last_bootstrap = time.time()

0 commit comments

Comments
 (0)