[init-delay-postgres] init delay transform epsilon

primedata-ai · Apr 16, 2021 · 8b81ba1 · 8b81ba1
1 parent 8878b6c
commit 8b81ba1
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/job/storage/postgres/postgres.go b/job/storage/postgres/postgres.go
@@ -43,9 +43,16 @@ func (d DB) GetAll() ([]*job.Job, error) {
 	}
 	err = nil
 	jobs := []*job.Job{}
+	result := make([]*job.Job, 0, len(jobs))
 	if r.Valid {
 		err = json.Unmarshal([]byte(r.String), &jobs)
 	}
+	for _, j := range jobs {
+		if err = j.InitDelayDuration(false); err != nil {
+			break
+		}
+		result = append(result, j)
+	}
 	return jobs, err
 }