def wait_apply_yaml_to_ClusterAgent(self):
    res = self.wait_consumer()
    if (res == None):
        print('res is None')
        return 'process_fail'
    is_process_fail = self.check_res_fail(res)
    hcode = res['hcode']
    lcode = res['lcode']
    result = res['msg']['result']
    print('hcode :hcode,result', hcode, lcode, result)
    if is_process_fail:
        print('Fail Job:', res)
        return 'process_fail'
    elif ((hcode == 210) and (lcode == 2)):
        if (result == 'success'):
            return 'apply_success'
        elif (result == 'fail'):
            return 'apply_fail'
        elif (result == 'cancel'):
            return 'cancel'
        else:
            return 'process_fail'
    else:
        return 'process_fail'
def wait_apply_yaml_to_ClusterAgent(self):
    res = self.wait_consumer()
    if (res == None):
        print('res is None')
        return 'process_fail'
    is_process_fail = self.check_res_fail(res)
    hcode = res['hcode']
    lcode = res['lcode']
    result = res['msg']['result']
    print('hcode :hcode,result', hcode, lcode, result)
    if is_process_fail:
        print('Fail Job:', res)
        return 'process_fail'
    elif ((hcode == 210) and (lcode == 2)):
        if (result == 'success'):
            return 'apply_success'
        elif (result == 'fail'):
            return 'apply_fail'
        elif (result == 'cancel'):
            return 'cancel'
        else:
            return 'process_fail'
    else:
        return 'process_fail'