Add limit for getQueueHead call
Michael Avila committed
Jul 2, 2019 at 13:15 UTC
143e41570bca067d92bec85cfa5e5fe283946f21
1 file changed
+1
-1
provider/queue/queue.go
+1
-1
@@ -133,7 +133,7 @@ func (q *Queue) work() {
133
}
134
135
func (q *Queue) getQueueHead() (*query.Result, error) {
136
- qry := query.Query{Orders: []query.Order{query.OrderByKey{}}}
136
+ qry := query.Query{Orders: []query.Order{query.OrderByKey{}}, Limit: 1}
137
results, err := q.ds.Query(qry)
138
if err != nil {
139
return nil, err