2 |
|
|
3 |
|
import sys, getopt, string |
4 |
|
|
5 |
< |
from FwkJobRep.ReportParser import readJobReport |
5 |
> |
from ProdCommon.FwkJobRep.ReportParser import readJobReport |
6 |
|
from DashboardAPI import apmonSend, apmonFree |
7 |
|
|
8 |
|
|
58 |
|
# load FwkJobRep |
59 |
|
jobReport = readJobReport(input)[0] |
60 |
|
|
61 |
< |
exit_satus = '' |
61 |
> |
exit_status = '' |
62 |
|
|
63 |
|
# get ExitStatus of last error |
64 |
|
if len(jobReport.errors) != 0 : |
115 |
|
for action in report[protocol].keys() : |
116 |
|
try: size = float(report[protocol][action][2]) |
117 |
|
except: size = 'NULL' |
118 |
< |
try: time = float(report[protocol][action][3])*1000 |
118 |
> |
try: time = float(report[protocol][action][3])/1000 |
119 |
|
except: time = 'NULL' |
120 |
|
dashboard_report['io_'+protocol+'_'+action] = str(size)+'_'+str(time) |
121 |
|
|
134 |
|
for key in dashboard_report.keys() : |
135 |
|
exit_string += ';' + str(key) + '=' + str(dashboard_report[key]) |
136 |
|
|
137 |
+ |
|
138 |
+ |
|
139 |
|
return exit_string |
140 |
|
|
141 |
|
|