Merge "Allow for only iterating over the most 'fresh' jobs"

1 files changed, 10 insertions, 1 deletions

diff --git a/taskflow/tests/unit/jobs/test_zk_job.py b/taskflow/tests/unit/jobs/test_zk_job.py
index 2dd6d57..57a7119 100644
--- a/taskflow/tests/unit/jobs/test_zk_job.py
+++ b/taskflow/tests/unit/jobs/test_zk_job.py
@@ -67,6 +67,15 @@ class TestZookeeperJobs(test.TestCase):
             self.client.flush()
             self.assertTrue(self.board.connected)
 
+    def test_fresh_iter(self):
+        with connect_close(self.board):
+            book = p_utils.temporary_log_book()
+            self.board.post('test', book)
+            self.client.flush()
+
+            jobs = list(self.board.iterjobs(ensure_fresh=True))
+            self.assertEqual(1, len(jobs))
+
     def test_posting_received_raw(self):
         book = p_utils.temporary_log_book()
 
@@ -78,7 +87,7 @@ class TestZookeeperJobs(test.TestCase):
             self.client.flush()
 
             self.assertEqual(self.board, posted_job.board)
-            self.assertTrue(1, self.board.job_count)
+            self.assertEqual(1, self.board.job_count)
             self.assertIn(posted_job.uuid, [j.uuid
                                             for j in self.board.iterjobs()])