openstack/deb-python-kafka
Code Issues Proposed changes

remove unused exception instance variables

Browse Source
This commit is contained in:
Vetoshkin Nikita
2013-10-03 18:26:34 +04:00
committed by David Arthur
parent 7ac75c575c
commit 11f22fb3d7
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/consumer.py
View File

@@ -299,7 +299,7 @@ class SimpleConsumer(Consumer):
while count > 0: while count > 0:
try: try:
messages.append(next(iterator)) messages.append(next(iterator))
except StopIteration as exp: except StopIteration:
break break
count -= 1 count -= 1

2
kafka/producer.py
View File

@@ -112,7 +112,7 @@ class Producer(object):
try: try:
self.client.send_produce_request(reqs, acks=self.req_acks, self.client.send_produce_request(reqs, acks=self.req_acks,
timeout=self.ack_timeout) timeout=self.ack_timeout)
except Exception as exp: except Exception:
log.error("Error sending message", exc_info=sys.exc_info()) log.error("Error sending message", exc_info=sys.exc_info())
def send_messages(self, partition, *msg): def send_messages(self, partition, *msg):