Skip to content
Snippets Groups Projects
Verified Commit 014bde97 authored by Volker Schukai's avatar Volker Schukai :alien:
Browse files

fix: sql doesn´t work #70

parent 76cb1ad6
No related branches found
No related tags found
No related merge requests found
...@@ -148,19 +148,12 @@ func update(job *JobPersistence, db *gorm.DB) error { ...@@ -148,19 +148,12 @@ func update(job *JobPersistence, db *gorm.DB) error {
var stats JobStats var stats JobStats
tx.Model(job.Stats).Where("job_id = ?", job.ID). tx.Model(job.Stats).Where("job_id = ?", job.ID).
Assign(job.Stats). Assign(job.Stats).
Omit("job_id", "created_at").
FirstOrCreate(&stats) FirstOrCreate(&stats)
//if tx.Error != nil { tx.Model(job.Stats).
// return tx.Error Select("*").
//} Omit("job_id", "created_at").
Updates(job.Stats)
//if err := tx.Model(job.Stats).
// Select("*").
// Omit("job_id", "created_at").
// Updates(job.Stats).Error; err != nil {
// return err // Fehler beim Update
//}
} }
for i := range job.Logs { for i := range job.Logs {
......
...@@ -249,7 +249,9 @@ func (m *Manager) ResetJobStats(id JobID) error { ...@@ -249,7 +249,9 @@ func (m *Manager) ResetJobStats(id JobID) error {
m.mu.Lock() m.mu.Lock()
defer m.mu.Unlock() defer m.mu.Unlock()
if _, ok := m.activeJobs[id]; !ok { if job, ok := m.activeJobs[id]; ok {
job.ResetStats()
} else {
return ErrJobNotActive return ErrJobNotActive
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment