def wait_request_clusters_latency_from_clusterAgent(self):
    ordered_cluster_list = []
    res = self.wait_consumer()
    if (res == None):
        print('res is None')
        return ('process_fail', ordered_cluster_list)
    is_process_fail = self.check_res_fail(res)
    hcode = res['hcode']
    lcode = res['lcode']
    result = res['msg']['result']
    '\n        result: [ {cluster: c3, latency: 11 },\n                  {cluster: c2, latency: 34 } ]\n        '
    if is_process_fail:
        print('Fail Job:', res)
        return ('process_fail', ordered_cluster_list)
    elif ((hcode == 200) and (lcode == 2)):
        for item in result:
            ordered_cluster_list.append(item['cluster'])
        return ('process_success', ordered_cluster_list)
    else:
        return ('process_fail', ordered_cluster_list)
def wait_request_clusters_latency_from_clusterAgent(self):
    ordered_cluster_list = []
    res = self.wait_consumer()
    if (res == None):
        print('res is None')
        return ('process_fail', ordered_cluster_list)
    is_process_fail = self.check_res_fail(res)
    hcode = res['hcode']
    lcode = res['lcode']
    result = res['msg']['result']
    '\n        result: [ {cluster: c3, latency: 11 },\n                  {cluster: c2, latency: 34 } ]\n        '
    if is_process_fail:
        print('Fail Job:', res)
        return ('process_fail', ordered_cluster_list)
    elif ((hcode == 200) and (lcode == 2)):
        for item in result:
            ordered_cluster_list.append(item['cluster'])
        return ('process_success', ordered_cluster_list)
    else:
        return ('process_fail', ordered_cluster_list)