From 48cef9ba948f3df7cc3ce428bb5a196887b9ccc3 Mon Sep 17 00:00:00 2001 From: shoopea Date: Tue, 11 Jun 2019 12:00:43 +0800 Subject: [PATCH] test --- job.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)