fix: change analysis top users to core hours

ClusterCockpit · Aug 24, 2023 · 4eceab4 · 4eceab4
1 parent 6a1e351
commit 4eceab4
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/internal/repository/job.go b/internal/repository/job.go
@@ -478,6 +478,12 @@ func (r *JobRepository) CountGroupedJobs(
 			now := time.Now().Unix()
 			count = fmt.Sprintf(`sum(job.num_nodes * (CASE WHEN job.job_state = "running" THEN %d - job.start_time ELSE job.duration END)) as count`, now)
 			runner = r.DB
+		case model.WeightsCoreCount:
+			count = "sum(job.num_hwthreads) as count"
+		case model.WeightsCoreHours:
+			now := time.Now().Unix()
+			count = fmt.Sprintf(`sum(job.num_hwthreads * (CASE WHEN job.job_state = "running" THEN %d - job.start_time ELSE job.duration END)) as count`, now)
+			runner = r.DB
 		default:
 			log.Debugf("CountGroupedJobs() Weight %v unknown.", *weight)
 		}

diff --git a/web/frontend/src/Analysis.root.svelte b/web/frontend/src/Analysis.root.svelte
@@ -67,7 +67,7 @@
                     histNumNodes { count, value }
                 }
 
-                topUsers: jobsCount(filter: $jobFilters, groupBy: USER, weight: NODE_HOURS, limit: 5) { name, count }
+                topUsers: jobsCount(filter: $jobFilters, groupBy: USER, weight: CORE_HOURS, limit: 5) { name, count }
             }
         `, 
         variables: { jobFilters }
@@ -172,7 +172,7 @@
         </Col>
         <Col>
             <Table>
-                <tr class="mb-2"><th>Legend</th><th>User Name</th><th>Node Hours</th></tr>
+                <tr class="mb-2"><th>Legend</th><th>User Name</th><th>Core Hours</th></tr>
                 {#each $statsQuery.data.topUsers.sort((a, b) => b.count - a.count) as { name, count }, i}
                     <tr>
                         <td><Icon name="circle-fill" style="color: {colors[i]};"/></td>