paulmataruso/zulip
1
0
Fork 0
mirror of https://github.com/zulip/zulip.git synced 2025-11-04 14:03:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

pep8: Fix many rule E128 violations.

Browse Source 
[Tweaked by tabbott to adjust some approaches used in wrapping]
This commit is contained in:
nikolay
2016-12-03 01:04:17 +02:00
committed by Tim Abbott
parent 144d82305d
commit abc2ff4a06
46 changed files with 253 additions and 249 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
zerver/lib/queue.py
View File

@@ -132,8 +132,8 @@ class SimpleQueueClient(object):
self.consumers[queue_name].add(wrapped_consumer)
self.ensure_queue(queue_name,
lambda: self.channel.basic_consume(wrapped_consumer, queue=queue_name,
consumer_tag=self._generate_ctag(queue_name)))
lambda: self.channel.basic_consume(wrapped_consumer, queue=queue_name,
consumer_tag=self._generate_ctag(queue_name)))
def register_json_consumer(self, queue_name, callback):
# type: (str, Callable[[Mapping[str, Any]], None]) -> None
@@ -276,8 +276,8 @@ class TornadoQueueClient(SimpleQueueClient):
self.consumers[queue_name].add(wrapped_consumer)
self.ensure_queue(queue_name,
lambda: self.channel.basic_consume(wrapped_consumer, queue=queue_name,
consumer_tag=self._generate_ctag(queue_name)))
lambda: self.channel.basic_consume(wrapped_consumer, queue=queue_name,
consumer_tag=self._generate_ctag(queue_name)))
queue_client = None # type: Optional[SimpleQueueClient]
def get_queue_client():