From e264120b04a054337e6b156e111de2f6056ad40a Mon Sep 17 00:00:00 2001 From: shoopea Date: Fri, 10 May 2019 17:32:08 +0800 Subject: [PATCH] test --- sql.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql.go b/sql.go index fbc2d16..4102391 100644 --- a/sql.go +++ b/sql.go @@ -1385,7 +1385,7 @@ func loadCurrentJobs() ([]Job, error) { } defer tx.Rollback() - stmt, err := tx.Prepare("SELECT o.id, o.obj_sub_type_id, j.payload FROM obj_job j, obj o WHERE j.obj_id = o.id AND j.status = ? AND j.schedule <= ? ORDER BY j.prio ASC LIMIT ? FOR UPDATE;") + stmt, err := tx.Prepare("SELECT o.id, o.obj_sub_type_id, j.payload FROM obj_job j, obj o WHERE j.obj_id = o.id AND j.status = ? AND j.schedule <= ? ORDER BY j.priority ASC LIMIT ? FOR UPDATE;") logOnError(err, "loadCurrentJobs : prepare select statement") rows, err := stmt.Query(objJobStatusNew, time.Now(), SQLJobSliceSize)