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)