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