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

fix: save data

parent b9c4fb78
No related branches found
No related tags found
No related merge requests found
......@@ -104,9 +104,17 @@ func createOrUpdateJob(job GenericJob, db *gorm.DB) error {
}
} else {
tx.Unscoped().Model(&existingJob).Where("id = ?", existingJob.ID).Select("*").Omit("deleted_at", "created_at", "job_id").Update("deleted_at", nil)
// remove deleted from
r := tx.Unscoped().Model(&existingJob).Where("id = ?", existingJob.ID).Select("*").
Omit("deleted_at", "created_at", "job_id").Update("deleted_at", nil)
if r.Error != nil {
Trace("Error while deleting job", "error", r.Error)
return r.Error
}
tx.Model(&existingJob).Where("id = ?", existingJob.ID).Select("*").Omit("deleted_at", "created_at", "job_id").UpdateColumns(SchedulerPersistence{
// update scheduler
resultStats := tx.Model(&existingJob).Where("id = ?", existingJob.ID).Select("*").
Omit("deleted_at", "created_at", "job_id").UpdateColumns(SchedulerPersistence{
Type: "",
Interval: 0,
Spec: "",
......@@ -116,9 +124,15 @@ func createOrUpdateJob(job GenericJob, db *gorm.DB) error {
Executed: false,
})
err := tx.Model(&existingJob).Updates(permJob).Error
if err != nil {
return err
if resultStats.Error != nil {
Trace("Error while updating job stats", "error", resultStats.Error)
return resultStats.Error
}
r2 := tx.Model(&existingJob).Where("id = ?", existingJob.ID).Select("*").
Omit("deleted_at", "created_at", "job_id").Updates(permJob)
if r2.Error != nil {
return r2.Error
}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment