ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2024-12-26 21:39:06 +01:00
Code Issues Packages Releases Activity

expand check, change to zero init

Browse Source
This commit is contained in:
Christoph Kluge 2024-11-22 16:31:35 +01:00
parent 5f4a74f8ba
commit 00ddc462d2
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
internal/taskManager/updateFootprintService.go
View File

@ -76,19 +76,21 @@ func RegisterFootprintWorker() {
Statistics: make(map[string]schema.JobStatistics), Statistics: make(map[string]schema.JobStatistics),
} }
for metric, data := range jobStats { // Metric, Hostname:Stats for metric := range jobStats { // Metric, Hostname:Stats
avg, min, max := 0.0, math.MaxFloat32, -math.MaxFloat32 avg, min, max := 0.0, 0.0, 0.0 // math.MaxFloat32, -math.MaxFloat32
for hostname := range data { data, ok := jobStats[metric]
hostStats, ok := data[hostname] if ok {
if !ok { for hostname := range data {
log.Debugf("footprintWorker: NAN stats returned for job %d @ %s", job.JobID, hostname) hostStats, ok := data[hostname]
} else { if ok {
log.Debugf("stats returned for job %d : %#v", job.JobID, hostStats) avg += hostStats.Avg
avg += hostStats.Avg min = math.Min(min, hostStats.Min)
min = math.Min(min, hostStats.Min) max = math.Max(max, hostStats.Max)
max = math.Max(max, hostStats.Max) }
} }
} else {
log.Debugf("no stats data return for job %d, metric %s", job.JobID, metric)
} }
// Add values rounded to 2 digits // Add values rounded to 2 digits