Fixes returning wrong items with start > 0

morpheu · Feb 24, 2012 · f639d77 · f639d77
1 parent 10f1ee3
commit f639d77
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pyes/es.py b/pyes/es.py
@@ -1496,7 +1496,7 @@ def __init__(self, connection, query, indices=None, doc_types=None, query_params
         self.start = self.query.start or 0
         self._max_item = self.query.size
         self._current_item = 0
-        self.chuck_size = self.query.bulk_read or 10
+        self.chuck_size = self.query.bulk_read or self.query.size or 10
 
     def _do_search(self, auto_increment=False):
         self.iterpos = 0