diff options
| author | mrtheb <mrlabbe@gmail.com> | 2013-10-03 22:52:04 -0400 |
|---|---|---|
| committer | mrtheb <mrlabbe@gmail.com> | 2013-10-03 22:52:04 -0400 |
| commit | a03f0c86b8a504c0e3185cac1611131dba24f625 (patch) | |
| tree | 3797524d3411640968292c6eba0141fc4c1f3457 /kafka/queue.py | |
| parent | b0cacc948539d180e4a634a06a10232770deb187 (diff) | |
| download | kafka-python-a03f0c86b8a504c0e3185cac1611131dba24f625.tar.gz | |
flake8 pass (pep8 and pyflakes)
Diffstat (limited to 'kafka/queue.py')
| -rw-r--r-- | kafka/queue.py | 19 |
1 files changed, 11 insertions, 8 deletions
diff --git a/kafka/queue.py b/kafka/queue.py index 41f1c31..a996369 100644 --- a/kafka/queue.py +++ b/kafka/queue.py @@ -25,8 +25,9 @@ class KafkaConsumerProcess(Process): Process.__init__(self) def __str__(self): - return "[KafkaConsumerProcess: topic=%s, partition=%s, sleep=%s]" % \ - (self.topic, self.partition, self.consumer_sleep) + return "[KafkaConsumerProcess: topic=%s, \ + partition=%s, sleep=%s]" % \ + (self.topic, self.partition, self.consumer_sleep) def run(self): self.barrier.wait() @@ -70,10 +71,12 @@ class KafkaProducerProcess(Process): Process.__init__(self) def __str__(self): - return "[KafkaProducerProcess: topic=%s, flush_buffer=%s, \ - flush_timeout=%s, timeout=%s]" % ( - self.topic, self.producer_flush_buffer, - self.producer_flush_timeout, self.producer_timeout) + return "[KafkaProducerProcess: topic=%s, \ + flush_buffer=%s, flush_timeout=%s, timeout=%s]" % \ + (self.topic, + self.producer_flush_buffer, + self.producer_flush_timeout, + self.producer_timeout) def run(self): self.barrier.wait() @@ -104,8 +107,8 @@ class KafkaProducerProcess(Process): last_produce = time.time() try: - msg = KafkaClient.create_message(self.in_queue.get(True, - self.producer_timeout)) + msg = KafkaClient.create_message( + self.in_queue.get(True, self.producer_timeout)) messages.append(msg) except Empty: |