openstack/deb-python-kafka
Code Issues Proposed changes

Remove unnecessary brackets

Browse Source
This commit is contained in:
Omar Ghishan
2014-01-03 17:40:07 -08:00
parent 6d2b28a59e
commit 57218546d7
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/consumer.py
View File

@@ -399,8 +399,8 @@ class SimpleConsumer(Consumer):
if self.max_buffer_size is None:
self.buffer_size *= 2
else:
self.buffer_size = max([self.buffer_size * 2,
self.max_buffer_size])
self.buffer_size = max(self.buffer_size * 2,
self.max_buffer_size)
log.warn("Fetch size too small, increase to %d (2x) "
"and retry", self.buffer_size)
retry_partitions.add(partition)