diff --git a/src/steps/common.py b/src/steps/common.py
index 2e52594..9b5e204 100644
--- a/src/steps/common.py
+++ b/src/steps/common.py
@@ -16,7 +16,7 @@ class StepsCommon:
         self.main_nodes = []
 
     @pytest.fixture(scope="function")
-    def setup_main_nodes(self, request):
+    def setup_2_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")
diff --git a/tests/data_integrity/test_data_integrity.py b/tests/data_integrity/test_data_integrity.py
index beac499..b1922a7 100644
--- a/tests/data_integrity/test_data_integrity.py
+++ b/tests/data_integrity/test_data_integrity.py
@@ -7,14 +7,13 @@ from src.test_data import DATA_TO_DISPERSE
 logger = get_custom_logger(__name__)
 
 
-@pytest.mark.usefixtures("setup_main_nodes")
 class TestDataIntegrity(StepsDataAvailability):
     main_nodes = []
 
     def test_da_identify_retrieve_missing_columns(self):
-        for node in self.main_nodes:
-            print(node)
+        self.disperse_data(DATA_TO_DISPERSE[0], [0] * 31 + [1], [0] * 8)
 
+    @pytest.mark.usefixtures("setup_2_node_cluster")
     def test_da_sampling_determines_data_presence(self):
         self.disperse_data(DATA_TO_DISPERSE[0], [0] * 31 + [1], [0] * 8)
         received_data = self.get_data_range([0] * 31 + [1], [0] * 8, [0] * 7 + [5])
diff --git a/tests/e2e/test_2node_alive.py b/tests/e2e/test_2node_alive.py
index 81273b0..fbf87d9 100644
--- a/tests/e2e/test_2node_alive.py
+++ b/tests/e2e/test_2node_alive.py
@@ -9,6 +9,6 @@ logger = get_custom_logger(__name__)
 
 
 class Test2NodeClAlive(StepsCommon):
-    @pytest.mark.usefixtures("setup_main_nodes")
+    @pytest.mark.usefixtures("setup_2_node_cluster")
     def test_cluster_start(self):
         logger.debug("Two node cluster started successfully!")