From 5d1b13ef2812ddfe619495178f41e57b1fb640df Mon Sep 17 00:00:00 2001 From: Benn Roth Date: Wed, 6 Dec 2017 08:31:24 -0800 Subject: changed for to use enumerate() (#1301) --- kafka/conn.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'kafka/conn.py') diff --git a/kafka/conn.py b/kafka/conn.py index 51a007c..2d6e5ce 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -747,13 +747,12 @@ class BrokerConnection(object): return () # augment respones w/ correlation_id, future, and timestamp - for i in range(len(responses)): + for i, response in enumerate(responses): (correlation_id, future, timestamp) = self.in_flight_requests.popleft() latency_ms = (time.time() - timestamp) * 1000 if self._sensors: self._sensors.request_time.record(latency_ms) - response = responses[i] log.debug('%s Response %d (%s ms): %s', self, correlation_id, latency_ms, response) responses[i] = (response, future) -- cgit v1.2.1