1 files changed, 26 insertions, 5 deletions
diff --git a/src/third_party/wiredtiger/test/suite/test_tiered03.py b/src/third_party/wiredtiger/test/suite/test_tiered03.py
index 670b2e4202c..4c870e366c2 100644..100755
--- a/src/third_party/wiredtiger/test/suite/test_tiered03.py
+++ b/src/third_party/wiredtiger/test/suite/test_tiered03.py
@@ -36,6 +36,9 @@ class test_tiered03(wttest.WiredTigerTestCase):
     K = 1024
     M = 1024 * K
     G = 1024 * M
+    # TODO: tiered: change this to a table: URI, otherwise we are
+    # not using tiered files.  The use of a second directory for
+    # sharing would probably need to be reworked.
     uri = 'file:test_tiered03'
 
     # Occasionally add a lot of records, so that merges (and bloom) happen.
@@ -44,12 +47,30 @@ class test_tiered03(wttest.WiredTigerTestCase):
 
     scenarios = wtscenario.make_scenarios(record_count_scenarios, prune=100, prunelong=500)
 
+    auth_token = "test_token"
+    bucket = "mybucket"
+    bucket_prefix = "pfx_"
+    extension_name = "local_store"
+    prefix = "pfx-"
+
+    def conn_config(self):
+        if not os.path.exists(self.bucket):
+            os.mkdir(self.bucket)
+        return \
+          'statistics=(all),' + \
+          'tiered_storage=(auth_token=%s,' % self.auth_token + \
+          'bucket=%s,' % self.bucket + \
+          'bucket_prefix=%s,' % self.prefix + \
+          'name=%s)' % self.extension_name
+
+    # Load the local store extension, but skip the test if it is missing.
+    def conn_extensions(self, extlist):
+        extlist.skip_if_missing = True
+        extlist.extension('storage_sources', self.extension_name)
+
     # Test sharing data between a primary and a secondary
     def test_sharing(self):
-        args = 'block_allocation=log-structured'
-        self.verbose(3,
-            'Test log-structured allocation with config: ' + args + ' count: ' + str(self.nrecs))
-        ds = SimpleDataSet(self, self.uri, 10, config=args)
+        ds = SimpleDataSet(self, self.uri, 10)
         ds.populate()
         ds.check()
         self.session.checkpoint()
@@ -71,7 +92,7 @@ class test_tiered03(wttest.WiredTigerTestCase):
         ds.check_cursor(cursor2)
         cursor2.close()
 
-        newds = SimpleDataSet(self, self.uri, 10000, config=args)
+        newds = SimpleDataSet(self, self.uri, 10000)
         newds.populate()
         newds.check()
         self.session.checkpoint()