### This file is only used for continuous evaluation test!

from __future__ import print_function

from __future__ import division

from __future__ import absolute_import

import os

import sys

sys.path.append(os.environ['ceroot'])

from kpi import CostKpi

from kpi import AccKpi

train_cost_kpi = CostKpi('train_cost', 0.02, 0, actived=True, desc='train cost')

train_acc_kpi = AccKpi('train_acc', 0.02, 0, actived=True, desc='train acc')

test_cost_kpi = CostKpi('test_cost', 0.02, 0, actived=True, desc='test cost')

test_acc_kpi = AccKpi('test_acc', 0.02, 0, actived=True, desc='test acc')

tracking_kpis = [train_cost_kpi, train_acc_kpi, test_cost_kpi, test_acc_kpi]

def parse_log(log):

for line in log.split('\n'):

fs = line.strip().split('\t')

print(fs)

if len(fs) == 3 and fs[0] == 'kpis':

kpi_name = fs[1]

kpi_value = float(fs[2])

yield kpi_name, kpi_value

def log_to_ce(log):

kpi_tracker = {}

for kpi in tracking_kpis:

kpi_tracker[kpi.name] = kpi

for (kpi_name, kpi_value) in parse_log(log):

print(kpi_name, kpi_value)

kpi_tracker[kpi_name].add_record(kpi_value)

kpi_tracker[kpi_name].persist()

if __name__ == '__main__':

log = sys.stdin.read()

log_to_ce(log)