diff --git a/job.go b/job.go index 4b0475d..e5a67de 100644 --- a/job.go +++ b/job.go @@ -107,7 +107,7 @@ func loadCurrentJobs() ([]Job, error) { jobs []Job ) - t := time.Now() + t := time.Now().UTC() r := RndInt64() _, err := db.Exec("UPDATE obj_job j SET j.pulled = ?, j.in_work = 1, j.seq_nr = ? WHERE j.is_done = 0 AND j.in_work = 0 AND j.schedule <= ? ORDER BY j.priority ASC, j.obj_id ASC LIMIT ?;", t, r, t, SQLJobSliceSize)