From 143e41570bca067d92bec85cfa5e5fe283946f21 Mon Sep 17 00:00:00 2001
From: Michael Avila <davidmichaelavila@gmail.com>
Date: Tue, 2 Jul 2019 13:15:14 -0700
Subject: [PATCH] Add limit for getQueueHead call

---
 provider/queue/queue.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/provider/queue/queue.go b/provider/queue/queue.go
index 293552233..ddaa97582 100644
--- 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