ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2025-07-23 12:51:40 +02:00
Code Issues Packages Releases Activity

Add FindRunningJobs to job repository

Browse Source
This commit is contained in:
Jan Eitzinger
2023-09-06 14:28:29 +02:00
parent e949f34e94
commit 8377e51608
3 changed files with 39 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
internal/repository/job.go
View File

@@ -290,6 +290,30 @@ func (r *JobRepository) FindById(jobId int64) (*schema.Job, error) {
return scanJob(q.RunWith(r.stmtCache).QueryRow())
}
func (r *JobRepository) FindRunningJobs(cluster string) (map[int64]*schema.Job, error) {
jobs := map[int64]*schema.Job{}
q := sq.Select(jobColumns...).From("job").Where("job.cluster = ?", cluster)
q = q.Where("job.job_state = ?", "running")
rows, err := q.RunWith(r.stmtCache).Query()
if err != nil {
log.Errorf("Error while querying running jobs: %v", err)
return nil, err
}
for rows.Next() {
job, err := scanJob(rows)
if err != nil {
rows.Close()
log.Warn("Error while scanning rows (Jobs)")
return nil, err
}
jobs[job.JobID] = job
}
return jobs, nil
}
func (r *JobRepository) FindConcurrentJobs(
ctx context.Context,
job *schema.Job) (*model.JobLinkResultList, error) {