diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-04-01 20:03:27 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-04-02 09:29:04 -0700 |
| commit | 1a532ff0f80c0d8244bb3f1a2ccf9f963f9db8c5 (patch) | |
| tree | c45729c17c93d665ac4d4134e176e555ae739a3d | |
| parent | bc4291535423b2adc762cbea1d65d09a6610358e (diff) | |
| download | kafka-python-1a532ff0f80c0d8244bb3f1a2ccf9f963f9db8c5.tar.gz | |
drop unused key_selector assignment
| -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 6eaa3db..eff8a2b 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -268,9 +268,9 @@ class KafkaClient(object): if node_id not in self._connecting: self._connecting.add(node_id) try: - key_selector = self._selector.register(sock, selectors.EVENT_WRITE) + self._selector.register(sock, selectors.EVENT_WRITE) except KeyError: - key_selector = self._selector.modify(sock, selectors.EVENT_WRITE) + self._selector.modify(sock, selectors.EVENT_WRITE) if self.cluster.is_bootstrap(node_id): self._last_bootstrap = time.time() |