In the threaded checkpoint test, make sure threads have finished before closing the connection.

1 files changed, 5 insertions, 3 deletions

diff --git a/test/suite/test_checkpoint02.py b/test/suite/test_checkpoint02.py
index 73999517e63..bff10ff65e0 100644
--- a/test/suite/test_checkpoint02.py
+++ b/test/suite/test_checkpoint02.py
@@ -56,15 +56,17 @@ class test_checkpoint02(wttest.WiredTigerTestCase):
                 queue.put_nowait(('b', i, my_data))
             queue.put_nowait(('i', i, my_data))
 
+        opthreads = []
         for i in xrange(self.nthreads):
             t = op_thread(self.conn, uris, self.fmt, queue, done)
+            opthreads.append(t)
             t.start()
 
         queue.join()
         done.set()
-        # Wait for checkpoint thread to notice status change.
-        while ckpt.is_alive():
-            time.sleep(0.01)
+        for t in opthreads:
+            t.join()
+        ckpt.join()
 
         # Create a cursor - ensure all items have been put.
         cursor = self.session.open_cursor(self.uri, None, None)