@staticmethod
def init(hosts, use_configuation_center, fate_flow_zk_path, fate_flow_port, model_transfer_path):
    if use_configuation_center:
        zk = CenterConfig.get_zk(hosts)
        zk.start()
        model_host = 'http://{}:{}{}'.format(get_lan_ip(), fate_flow_port, model_transfer_path)
        fate_flow_zk_path = '{}/{}'.format(fate_flow_zk_path, parse.quote(model_host, safe=' '))
        try:
            zk.create(fate_flow_zk_path, makepath=True)
        except:
            pass
        zk.stop()
@staticmethod
def init(hosts, use_configuation_center, fate_flow_zk_path, fate_flow_port, model_transfer_path):
    if use_configuation_center:
        zk = CenterConfig.get_zk(hosts)
        zk.start()
        model_host = 'http://{}:{}{}'.format(get_lan_ip(), fate_flow_port, model_transfer_path)
        fate_flow_zk_path = '{}/{}'.format(fate_flow_zk_path, parse.quote(model_host, safe=' '))
        try:
            zk.create(fate_flow_zk_path, makepath=True)
        except:
            pass
        zk.stop()