there is some places in this test where we do not use method get_rabbit_nodes , so we still has issue with parse output, like here
def count_run_rabbit(node, all_up=False):
with self.fuel_web.get_ssh_for_node(node.name) as remote:
cmd = 'rabbitmqctl cluster_status' with RunLimit(seconds=60, error_message=error.format(cmd)): out = run_on_remote(remote, cmd=cmd, raise_on_assert=False) run_nodes = [el for el in out if 'running_nodes' in el] run_nodes = run_nodes[0] if run_nodes else '' logger.debug('### Status for {} \n {}'.format(str(node.name), run_nodes)) expected_up = len(n_ctrls) if all_up else 1
return run_nodes.count('rabbit@') == expected_up
there is some places in this test where we do not use method get_rabbit_nodes , so we still has issue with parse output, like here rabbit( node, all_up=False): web.get_ ssh_for_ node(node. name) as remote:
with RunLimit( seconds= 60, error_message= error.format( cmd)):
out = run_on_ remote( remote, cmd=cmd, raise_on_ assert= False)
run_ nodes = [el for el in out if 'running_nodes' in el]
run_ nodes = run_nodes[0] if run_nodes else ''
logger. debug(' ### Status for {} \n {}'.format( str(node. name),
run_nodes) )
expected_ up = len(n_ctrls) if all_up else 1 count(' rabbit@ ') == expected_up
def count_run_
with self.fuel_
cmd = 'rabbitmqctl cluster_status'
return run_nodes.