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

more logging

Browse Source
This commit is contained in:
Christoph Kluge 2024-11-22 13:36:26 +01:00
parent 21b3a67988
commit 69f8a34aac
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
internal/taskManager/updateFootprintService.go
View File

@ -65,7 +65,7 @@ func RegisterFootprintWorker() {
jobStats, err := repo.LoadStats(job, allMetrics, context.Background()) jobStats, err := repo.LoadStats(job, allMetrics, context.Background())
if err != nil { if err != nil {
log.Errorf("Error wile loading job data stats for footprint update: %v", err) log.Errorf("error wile loading job data stats for footprint update: %v", err)
ce++ ce++
continue continue
} }
@ -101,7 +101,7 @@ func RegisterFootprintWorker() {
stmt := sq.Update("job") stmt := sq.Update("job")
stmt, err = jobRepo.UpdateFootprint(stmt, jobMeta) stmt, err = jobRepo.UpdateFootprint(stmt, jobMeta)
if err != nil { if err != nil {
log.Errorf("Update job (dbid: %d) statement build failed at footprint step: %s", job.ID, err.Error()) log.Errorf("update job (dbid: %d) statement build failed at footprint step: %s", job.ID, err.Error())
ce++ ce++
continue continue
} }
@ -114,24 +114,24 @@ func RegisterFootprintWorker() {
stmt = stmt.Where("job.id = ?", job.ID) stmt = stmt.Where("job.id = ?", job.ID)
pendingStatements = append(pendingStatements, stmt) pendingStatements = append(pendingStatements, stmt)
log.Debugf("Finish Job Preparation %d, took %s", job.JobID, time.Since(s_job)) log.Debugf("Job %d took %s", job.JobID, time.Since(s_job))
} }
log.Debugf("Finish preparation for %d jobs: %d statements", len(jobs), len(pendingStatements))
t, err := jobRepo.TransactionInit() t, err := jobRepo.TransactionInit()
if err != nil { if err != nil {
log.Errorf("Failed TransactionInit %v", err) log.Errorf("failed TransactionInit %v", err)
} }
for _, ps := range pendingStatements { for idx, ps := range pendingStatements {
query, args, err := ps.ToSql() query, args, err := ps.ToSql()
if err != nil { if err != nil {
log.Debugf(">>> Query: %v", query) log.Errorf("failed in ToSQL conversion: %v", err)
log.Debugf(">>> Args: %v", args)
log.Errorf("Failed in ToSQL conversion: %v", err)
ce++ ce++
} else { } else {
// Args: JSON, JSON, ENERGY, JOBID // Args: JSON, JSON, ENERGY, JOBID
log.Infof("add transaction on index %d", idx)
jobRepo.TransactionAdd(t, query, args...) jobRepo.TransactionAdd(t, query, args...)
c++ c++
} }