ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2026-03-15 04:17:30 +01:00
Code Issues Packages Releases Activity

Inline jobstate literal in query

Browse Source 
Entire-Checkpoint: 35f06df74b51
This commit is contained in:
Jan Eitzinger
2026-03-13 15:16:07 +01:00
parent df2a13def2
commit f15f1452cc
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/repository/job.go
View File

@@ -1066,7 +1066,7 @@ func (r *JobRepository) GetUsedNodes(ts int64) (map[string][]string, error) {
// Note: Query expects index on (job_state, start_time) for optimal performance // Note: Query expects index on (job_state, start_time) for optimal performance
q := sq.Select("job.cluster", "job.resources").From("job"). q := sq.Select("job.cluster", "job.resources").From("job").
Where("job.start_time < ?", ts). Where("job.start_time < ?", ts).
Where(sq.Eq{"job.job_state": "running"}) Where("job.job_state = 'running'")
rows, err := q.RunWith(r.stmtCache).Query() rows, err := q.RunWith(r.stmtCache).Query()
if err != nil { if err != nil {

2
internal/repository/stats.go
View File

@@ -113,7 +113,7 @@ func (r *JobRepository) buildCountQuery(
switch kind { switch kind {
case "running": case "running":
query = query.Where("job.job_state = ?", "running") query = query.Where("job.job_state = 'running'")
case "short": case "short":
query = query.Where("job.duration < ?", config.Keys.ShortRunningJobsDuration) query = query.Where("job.duration < ?", config.Keys.ShortRunningJobsDuration)
} }