summaryrefslogtreecommitdiff
path: root/kafka/util.py
diff options
context:
space:
mode:
authorMatthew L Daniel <mdaniel@gmail.com>2014-08-22 15:53:27 -0700
committerMatthew L Daniel <mdaniel@gmail.com>2014-08-22 16:01:02 -0700
commitbb3827eb2e13820e52c138ce81f4076199e2ae4f (patch)
tree3d0385f0fa4f9f7d78ac851f67466bd749222571 /kafka/util.py
parenta27e521fd7078a551eb09160e8880df6a509a987 (diff)
downloadkafka-python-bb3827eb2e13820e52c138ce81f4076199e2ae4f.tar.gz
PEP8 fixes
Diffstat (limited to 'kafka/util.py')
-rw-r--r--kafka/util.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/util.py b/kafka/util.py
index a918234..09a5bbb 100644
--- a/kafka/util.py
+++ b/kafka/util.py
@@ -16,7 +16,7 @@ def write_int_string(s):
def write_short_string(s):
if s is None:
return struct.pack('>h', -1)
- elif len(s) > 32767 and sys.version < (2,7):
+ elif len(s) > 32767 and sys.version < (2, 7):
# Python 2.6 issues a deprecation warning instead of a struct error
raise struct.error(len(s))
else:
@@ -117,4 +117,5 @@ class ReentrantTimer(object):
self.active.set()
self.thread.join(self.t + 1)
+ # noinspection PyAttributeOutsideInit
self.timer = None