database.go

@@ -142,12 +142,18 @@ func update(job *JobPersistence, db *gorm.DB) error {
 				Info("Stats runCount is 0, skipping update")
 			}
 
-			if err := tx.Model(job.Stats).
+			// if jobs.Stats not exists in database
+			// create new record
+			// else update existing record
+			var stats JobStats
+			tx.Model(job.Stats).Where("job_id = ?", job.ID).
+				Assign(job.Stats).
+				FirstOrCreate(&stats)
+
+			tx.Model(job.Stats).
 				Select("*").
 				Omit("job_id", "created_at").
-				Updates(job.Stats).Error; err != nil {
-				return err // Fehler beim Update
-			}
+				Updates(job.Stats)
 		}
 
 		for i := range job.Logs {
@@ -156,7 +162,7 @@ func update(job *JobPersistence, db *gorm.DB) error {
 			// no error handling, if it fails, it fails
 		}
 
-		return nil
+		return tx.Error
 	})
 }
 

manager.go

@@ -249,7 +249,9 @@ func (m *Manager) ResetJobStats(id JobID) error {
 	m.mu.Lock()
 	defer m.mu.Unlock()
 
-	if _, ok := m.activeJobs[id]; !ok {
+	if job, ok := m.activeJobs[id]; ok {
+		job.ResetStats()
+	} else {
 		return ErrJobNotActive
 	}