def apply_yaml_to_ClusterAgent(self, cluster):
    print('apply_yaml_to_ClusterAgent:', cluster)
    try:
        temp_msg = {'source': {'type': 'none'}, 'target': {'type': 'cluster', 'object': cluster}, 'hcode': 210, 'lcode': 1, 'msg': {'requestID': self.requestID, 'fileID': self.fileID, 'requestData': self.requestDataDic}}
        self.producer.send(lowDefine.GLOBAL_SCHEDULER_GLOBAL_TOPIC_NAME, value=temp_msg)
        self.producer.flush()
    except:
        return 'process_fail'
    return 'process_success'
def apply_yaml_to_ClusterAgent(self, cluster):
    print('apply_yaml_to_ClusterAgent:', cluster)
    try:
        temp_msg = {'source': {'type': 'none'}, 'target': {'type': 'cluster', 'object': cluster}, 'hcode': 210, 'lcode': 1, 'msg': {'requestID': self.requestID, 'fileID': self.fileID, 'requestData': self.requestDataDic}}
        self.producer.send(lowDefine.GLOBAL_SCHEDULER_GLOBAL_TOPIC_NAME, value=temp_msg)
        self.producer.flush()
    except:
        return 'process_fail'
    return 'process_success'