diff --git a/cluster_config/cfgsync.yaml b/cluster_config/cfgsync.yaml
index 10840a5..dde1f71 100644
--- a/cluster_config/cfgsync.yaml
+++ b/cluster_config/cfgsync.yaml
@@ -1,5 +1,5 @@
 port: 4400
-n_hosts: 2
+n_hosts: 5
 timeout: 30
 
 # ConsensusConfig related parameters
diff --git a/src/steps/common.py b/src/steps/common.py
index 9b5e204..78a905b 100644
--- a/src/steps/common.py
+++ b/src/steps/common.py
@@ -32,3 +32,30 @@ class StepsCommon:
         except Exception as ex:
             logger.error(f"REST service did not become ready in time: {ex}")
             raise
+
+    @pytest.fixture(scope="function")
+    def setup_5_node_cluster(self, request):
+        logger.debug(f"Running fixture setup: {inspect.currentframe().f_code.co_name}")
+        self.node1 = NomosNode(CFGSYNC, "cfgsync")
+        self.node2 = NomosNode(NOMOS, "nomos_node_0")
+        self.node3 = NomosNode(NOMOS, "nomos_node_1")
+        self.node4 = NomosNode(NOMOS, "nomos_node_2")
+        self.node5 = NomosNode(NOMOS, "nomos_node_3")
+        self.node6 = NomosNode(NOMOS_EXECUTOR, "nomos_node_4")
+        self.node1.start()
+        self.node2.start()
+        self.node3.start()
+        self.node4.start()
+        self.node5.start()
+        self.node6.start()
+        self.main_nodes.extend([self.node1, self.node2, self.node3, self.node4, self.node5, self.node6])
+
+        try:
+            self.node2.ensure_ready()
+            self.node3.ensure_ready()
+            self.node4.ensure_ready()
+            self.node5.ensure_ready()
+            self.node6.ensure_ready()
+        except Exception as ex:
+            logger.error(f"REST service did not become ready in time: {ex}")
+            raise
diff --git a/tests/data_integrity/test_data_integrity.py b/tests/data_integrity/test_data_integrity.py
index b1922a7..f209110 100644
--- a/tests/data_integrity/test_data_integrity.py
+++ b/tests/data_integrity/test_data_integrity.py
@@ -10,6 +10,7 @@ logger = get_custom_logger(__name__)
 class TestDataIntegrity(StepsDataAvailability):
     main_nodes = []
 
+    @pytest.mark.usefixtures("setup_5_node_cluster")
     def test_da_identify_retrieve_missing_columns(self):
         self.disperse_data(DATA_TO_DISPERSE[0], [0] * 31 + [1], [0] * 8)