Add limit for getQueueHead call

ralendor · Jun 6, 2020 · 437c832 · 437c832
1 parent c787b07
commit 437c832
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/provider/queue/queue.go b/provider/queue/queue.go
@@ -133,7 +133,7 @@ func (q *Queue) work() {
 }
 
 func (q *Queue) getQueueHead() (*query.Result, error) {
-	qry := query.Query{Orders: []query.Order{query.OrderByKey{}}}
+	qry := query.Query{Orders: []query.Order{query.OrderByKey{}}, Limit: 1}
 	results, err := q.ds.Query(qry)
 	if err != nil {
 		return nil, err