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

Initial attempt to update footprints in transaction

Browse Source
This commit is contained in:
Jan Eitzinger 2024-09-03 15:59:01 +02:00
parent e267481f71
commit 508978d586
2 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/archiver/archiver.go
View File

@ -24,7 +24,8 @@ func ArchiveJob(job *schema.Job, ctx context.Context) (*schema.JobMeta, error) {
} }
scopes := []schema.MetricScope{schema.MetricScopeNode} scopes := []schema.MetricScope{schema.MetricScopeNode}
if job.NumNodes <= 8 { // FIXME: Add a config option for this // FIXME: Add a config option for this
if job.NumNodes <= 8 {
// This will add the native scope if core scope is not available // This will add the native scope if core scope is not available
scopes = append(scopes, schema.MetricScopeCore) scopes = append(scopes, schema.MetricScopeCore)
} }

20
internal/taskManager/updateFootprintService.go
View File

@ -25,6 +25,12 @@ func RegisterFootprintWorker() {
func() { func() {
s := time.Now() s := time.Now()
log.Printf("Update Footprints started at %s", s.Format(time.RFC3339)) log.Printf("Update Footprints started at %s", s.Format(time.RFC3339))
t, err := jobRepo.TransactionInit()
if err != nil {
log.Errorf("Failed TransactionInit %v", err)
}
for _, cluster := range archive.Clusters { for _, cluster := range archive.Clusters {
jobs, err := jobRepo.FindRunningJobs(cluster.Name) jobs, err := jobRepo.FindRunningJobs(cluster.Name)
if err != nil { if err != nil {
@ -87,12 +93,22 @@ func RegisterFootprintWorker() {
log.Errorf("Update job (dbid: %d) failed at update Energy step: %s", job.ID, err.Error()) log.Errorf("Update job (dbid: %d) failed at update Energy step: %s", job.ID, err.Error())
continue continue
} }
if err := jobRepo.Execute(stmt); err != nil {
log.Errorf("Update job (dbid: %d) failed at db execute: %s", job.ID, err.Error()) query, args, err := stmt.ToSql()
if err != nil {
log.Errorf("Failed in ToSQL conversion %v", err)
continue continue
} }
jobRepo.TransactionAdd(t, query, args)
// if err := jobRepo.Execute(stmt); err != nil {
// log.Errorf("Update job (dbid: %d) failed at db execute: %s", job.ID, err.Error())
// continue
// }
} }
jobRepo.TransactionCommit(t)
} }
jobRepo.TransactionEnd(t)
log.Printf("Update Footprints is done and took %s", time.Since(s)) log.Printf("Update Footprints is done and took %s", time.Since(s))
})) }))
} }