fixed pep8 issue E265
* E265 block comment should start with '# ' E265 was introduced in pep8 1.5 (2014-03-26). Change-Id: I076addadd2e67a8ac4162c706a36239f4af37a8c
This commit is contained in:
parent
ea989b8f95
commit
ab88dfb887
|
@ -296,7 +296,7 @@ class CommonRpcContext(object):
|
||||||
return self.from_dict(self.to_dict())
|
return self.from_dict(self.to_dict())
|
||||||
|
|
||||||
def update_store(self):
|
def update_store(self):
|
||||||
#local.store.context = self
|
# local.store.context = self
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -329,7 +329,7 @@ class ConsumerBase(object):
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def normalize_reply(self, result, replies):
|
def normalize_reply(self, result, replies):
|
||||||
#TODO(ewindisch): re-evaluate and document this method.
|
# TODO(ewindisch): re-evaluate and document this method.
|
||||||
if isinstance(result, types.GeneratorType):
|
if isinstance(result, types.GeneratorType):
|
||||||
return list(result)
|
return list(result)
|
||||||
elif replies:
|
elif replies:
|
||||||
|
@ -547,7 +547,7 @@ class ZmqReactor(ZmqBaseReactor):
|
||||||
super(ZmqReactor, self).__init__(conf)
|
super(ZmqReactor, self).__init__(conf)
|
||||||
|
|
||||||
def consume(self, sock):
|
def consume(self, sock):
|
||||||
#TODO(ewindisch): use zero-copy (i.e. references, not copying)
|
# TODO(ewindisch): use zero-copy (i.e. references, not copying)
|
||||||
data = sock.recv()
|
data = sock.recv()
|
||||||
LOG.debug("CONSUMER RECEIVED DATA: %s", data)
|
LOG.debug("CONSUMER RECEIVED DATA: %s", data)
|
||||||
|
|
||||||
|
|
|
@ -126,10 +126,10 @@ class MatchMakerBase(object):
|
||||||
def add_binding(self, binding, rule, last=True):
|
def add_binding(self, binding, rule, last=True):
|
||||||
self.bindings.append((binding, rule, False, last))
|
self.bindings.append((binding, rule, False, last))
|
||||||
|
|
||||||
#NOTE(ewindisch): kept the following method in case we implement the
|
# NOTE(ewindisch): kept the following method in case we implement the
|
||||||
# underlying support.
|
# underlying support.
|
||||||
#def add_negate_binding(self, binding, rule, last=True):
|
# def add_negate_binding(self, binding, rule, last=True):
|
||||||
# self.bindings.append((binding, rule, True, last))
|
# self.bindings.append((binding, rule, True, last))
|
||||||
|
|
||||||
def queues(self, key):
|
def queues(self, key):
|
||||||
workers = []
|
workers = []
|
||||||
|
|
Loading…
Reference in New Issue