def __init__(self, template_id, ps_replicas, worker_replicas, training_step, batch_size, interval, task_id, rtimes, tag):
    self.template_id = template_id
    self.ps_replicas = ps_replicas
    self.worker_replicas = worker_replicas
    self.training_step = training_step
    self.interval = interval
    self.batch_size = batch_size
    self.task_id = task_id
    self.tag = tag
    self.rtimes = rtimes
    self.influx_client = influxdb.InfluxDBClient(host='192.168.128.10', port=8086, username='admin', password='admin', database='NODEMESSAGE')
    self.node_list = ['k8s-master', 'k8s-worker0', 'k8s-worker2', 'k8sworker1', 'k8s-worker3', 'k8s-worker4', 'k8s-worker5']
    self.node_cpu = {}
    self.node_cpu['k8s-master'] = 32000
    self.node_cpu['k8s-worker0'] = 24000
    self.node_cpu['k8s-worker2'] = 24000
    self.node_cpu['k8sworker1'] = 16000
    self.node_cpu['k8s-worker3'] = 24000
    self.node_cpu['k8s-worker4'] = 16000
    self.node_cpu['k8s-worker5'] = 24000
    self.node_memory = {}
    self.node_memory['k8s-master'] = float((251 * 1024))
    self.node_memory['k8s-worker0'] = float((94 * 1024))
    self.node_memory['k8s-worker2'] = float((94 * 1024))
    self.node_memory['k8sworker1'] = float((125 * 1024))
    self.node_memory['k8s-worker3'] = float((94 * 1024))
    self.node_memory['k8s-worker4'] = float((125 * 1024))
    self.node_memory['k8s-worker5'] = float((94 * 1024))
    self.args = [('--training_step=' + str(self.training_step)), ('--batch_size=' + str(self.batch_size)), ('--interval=' + str(self.interval)), ('--task_id=' + str(self.task_id)), ('--rtimes=' + str(self.rtimes)), ('--tag=' + self.tag)]
def __init__(self, template_id, ps_replicas, worker_replicas, training_step, batch_size, interval, task_id, rtimes, tag):
    self.template_id = template_id
    self.ps_replicas = ps_replicas
    self.worker_replicas = worker_replicas
    self.training_step = training_step
    self.interval = interval
    self.batch_size = batch_size
    self.task_id = task_id
    self.tag = tag
    self.rtimes = rtimes
    self.influx_client = influxdb.InfluxDBClient(host='192.168.128.10', port=8086, username='admin', password='admin', database='NODEMESSAGE')
    self.node_list = ['k8s-master', 'k8s-worker0', 'k8s-worker2', 'k8sworker1', 'k8s-worker3', 'k8s-worker4', 'k8s-worker5']
    self.node_cpu = {}
    self.node_cpu['k8s-master'] = 32000
    self.node_cpu['k8s-worker0'] = 24000
    self.node_cpu['k8s-worker2'] = 24000
    self.node_cpu['k8sworker1'] = 16000
    self.node_cpu['k8s-worker3'] = 24000
    self.node_cpu['k8s-worker4'] = 16000
    self.node_cpu['k8s-worker5'] = 24000
    self.node_memory = {}
    self.node_memory['k8s-master'] = float((251 * 1024))
    self.node_memory['k8s-worker0'] = float((94 * 1024))
    self.node_memory['k8s-worker2'] = float((94 * 1024))
    self.node_memory['k8sworker1'] = float((125 * 1024))
    self.node_memory['k8s-worker3'] = float((94 * 1024))
    self.node_memory['k8s-worker4'] = float((125 * 1024))
    self.node_memory['k8s-worker5'] = float((94 * 1024))
    self.args = [('--training_step=' + str(self.training_step)), ('--batch_size=' + str(self.batch_size)), ('--interval=' + str(self.interval)), ('--task_id=' + str(self.task_id)), ('--rtimes=' + str(self.rtimes)), ('--tag=' + self.tag)]