unit test passed for py27
Change-Id: Ia139fe0b0e1c498224e5d80541ea74e65eca000f
This commit is contained in:
parent
fb786600f4
commit
9accbeecd0
|
@ -275,6 +275,7 @@ expression = (
|
|||
class AlarmExprParser(object):
|
||||
def __init__(self, expr):
|
||||
self._expr = expr
|
||||
self._expr.encode('utf8').replace(' ', '')
|
||||
try:
|
||||
self.parseResult = (expression + pyparsing.stringEnd).parseString(
|
||||
self._expr.replace(' ', ''))[0]
|
||||
|
|
|
@ -47,9 +47,9 @@ KAFKA_OPTS = [
|
|||
help=('Specify if the message received should be parsed. '
|
||||
'If True, message will not be parsed, otherwise '
|
||||
'messages will be parsed.')),
|
||||
cfg.MultiOpt('partitions', item_type=types.Integer(),
|
||||
default=[0],
|
||||
help='The sleep time when no messages on kafka queue.'),
|
||||
cfg.ListOpt('partitions', item_type=types.String(),
|
||||
default=[0],
|
||||
help='The sleep time when no messages on kafka queue.'),
|
||||
cfg.BoolOpt('drop_data', default=False,
|
||||
help=('Specify if received data should be simply dropped. '
|
||||
'This parameter is only for testing purposes.')),
|
||||
|
|
|
@ -19,4 +19,4 @@ stevedore>=0.14
|
|||
ujson>=1.33
|
||||
babel
|
||||
eventlet
|
||||
pyparsing
|
||||
pyparsing==2.0.1
|
||||
|
|
Loading…
Reference in New Issue