def request_clusters_latency_from_clusterAgent(self, clusters):
    try:
        temp_msg = {'source': {'type': 'none'}, 'target': {'type': 'cluster', 'object': self.sourceCluster}, 'hcode': 200, 'lcode': 1, 'msg': {'requestID': self.requestID, 'sourceNode': self.sourceNode, 'targetClusters': clusters}}
        self.producer.send(lowDefine.GLOBAL_SCHEDULER_GLOBAL_TOPIC_NAME, value=temp_msg)
        self.producer.flush()
    except:
        return 'process_fail'
    return 'process_success'
def request_clusters_latency_from_clusterAgent(self, clusters):
    try:
        temp_msg = {'source': {'type': 'none'}, 'target': {'type': 'cluster', 'object': self.sourceCluster}, 'hcode': 200, 'lcode': 1, 'msg': {'requestID': self.requestID, 'sourceNode': self.sourceNode, 'targetClusters': clusters}}
        self.producer.send(lowDefine.GLOBAL_SCHEDULER_GLOBAL_TOPIC_NAME, value=temp_msg)
        self.producer.flush()
    except:
        return 'process_fail'
    return 'process_success'