diff --git a/mrq/worker.py b/mrq/worker.py
index <HASH>..<HASH> 100644
--- a/mrq/worker.py
+++ b/mrq/worker.py
@@ -481,7 +481,7 @@ class Worker(object):
 
                 # At the next pass, start at the next queue to avoid always dequeuing the same one
                 if self.config["dequeue_strategy"] == "parallel":
-                    queue_offset += queue_i + 1
+                    queue_offset = (queue_offset + queue_i + 1) % len(self.queues)
 
                 for job in jobs:
Add bounds on the queue_offset