Add debug output to duration query

ClusterCockpit · Sep 5, 2024 · 53ca38c · 53ca38c
1 parent 508978d
commit 53ca38c
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/internal/repository/job.go b/internal/repository/job.go
@@ -484,10 +484,14 @@ func (r *JobRepository) FindRunningJobs(cluster string) ([]*schema.Job, error) {
 }
 
 func (r *JobRepository) UpdateDuration() error {
-	if _, err := sq.Update("job").
+	stmnt := sq.Update("job").
 		Set("duration", sq.Expr("? - job.start_time", time.Now().Unix())).
-		Where("job_state = running").
-		RunWith(r.stmtCache).Exec(); err != nil {
+		Where("job_state = running")
+	sql, _, err := stmnt.ToSql()
+	log.Infof("Duration Update query %s", sql)
+
+	_, err = stmnt.RunWith(r.stmtCache).Exec()
+	if err != nil {
 		return err
 	}