--- Revision None
+++ Revision 386432646161
@@ -0,0 +1,32 @@
+diff --git a/pytests/viewtests.py b/pytests/viewtests.py
+index 7164907..e8cb215 100644
+--- a/pytests/viewtests.py
++++ b/pytests/viewtests.py
+@@ -251,10 +251,10 @@ class ViewTests(unittest.TestCase):
+             moxi.set(key, 0, 0, json.dumps(value))
+         self.log.info("inserted {0} json documents".format(num_of_docs))
+         #        self._verify_views_replicated(bucket, view_name, map_fn)
+-        results = self._get_view_results(rest, bucket, view_name, num_of_docs)
++        results = self._get_view_results(rest, bucket, view_name, num_of_docs, extra_params={"stale": False})
+         value = self._get_built_in_reduce_results(results)
+         results_without_reduce = self._get_view_results(rest, bucket, view_name, num_of_docs,
+-                                                        extra_params={"reduce": False})
++                                                        extra_params={"reduce": False, "stale": False})
+         #TODO: we should extend this function to wait for disk_write_queue for all nodes
+         RebalanceHelper.wait_for_stats(master, bucket, 'ep_queue_size', 0)
+         # try this for maximum 3 minutes
+@@ -269,12 +269,12 @@ class ViewTests(unittest.TestCase):
+             attempt += 1
+             #get the results without reduce ?
+             results_without_reduce = self._get_view_results(rest, bucket, view_name, num_of_docs,
+-                                                            extra_params={"reduce": False})
++                                                            extra_params={"reduce": False, "stale": False})
+             keys = self._get_keys(results_without_reduce)
+             num_of_results_without_reduce = len(keys)
+             msg = "view with reduce=false returned {0} items, expected to return {1} items"
+             self.log.info(msg.format(len(keys), len(doc_names)))
+-            results = self._get_view_results(rest, bucket, view_name, num_of_docs)
++            results = self._get_view_results(rest, bucket, view_name, num_of_docs, extra_params={"stale": False})
+             value = self._get_built_in_reduce_results(results)
+             msg = "reduce returned {0}, expected to return {1}"
+             self.log.info(msg.format(value, len(doc_names)))