From 8606408a8a233d920d7889d9bb5bd5494d7c26f0 Mon Sep 17 00:00:00 2001 From: Mahesh Shetty Date: Wed, 13 Nov 2024 14:30:16 +0530 Subject: [PATCH] fix up Signed-off-by: Mahesh Shetty --- ocs_ci/ocs/resources/stretchcluster.py | 10 ---------- .../disaster-recovery/sc_arbiter/test_netsplit.py | 8 -------- 2 files changed, 18 deletions(-) diff --git a/ocs_ci/ocs/resources/stretchcluster.py b/ocs_ci/ocs/resources/stretchcluster.py index 1d12df77e3a7..f7309823e68c 100644 --- a/ocs_ci/ocs/resources/stretchcluster.py +++ b/ocs_ci/ocs/resources/stretchcluster.py @@ -205,11 +205,6 @@ def check_for_read_pause(self, label, start_time, end_time): max_fail_expected = len(self.workload_map[label][0]) - 2 failed = 0 for pod_obj in self.workload_map[label][0]: - # if get_pod_node(pod_obj).name in self.non_quorum_nodes: - # logger.info( - # f"Not checking the logs from {pod_obj.name} as it belongs to non-quorum zone" - # ) - # continue try: pause_count = 0 time_var = start_time @@ -256,11 +251,6 @@ def check_for_write_pause(self, label, start_time, end_time): ) failed = 0 for pod_obj in self.workload_map[label][0]: - # if get_pod_node(pod_obj).name in self.non_quorum_nodes: - # logger.info( - # f"Not checking the logs from {pod_obj.name} as it belongs to non-quorum zone" - # ) - # continue no_such_file_expected = 1 for file_name in self.logfile_map[label][0]: pause_count = 0 diff --git a/tests/functional/disaster-recovery/sc_arbiter/test_netsplit.py b/tests/functional/disaster-recovery/sc_arbiter/test_netsplit.py index 752f1ab15b39..b1b37dab416d 100644 --- a/tests/functional/disaster-recovery/sc_arbiter/test_netsplit.py +++ b/tests/functional/disaster-recovery/sc_arbiter/test_netsplit.py @@ -195,14 +195,6 @@ def test_netsplit( ) logger.info(f"Netsplit induced at {start_time} for zones {zones}") - # get the nodes which are present in the - # out of quorum zone - # if ( - # zones != constants.NETSPLIT_ARBITER_DATA_1 - # and zones != constants.NETSPLIT_ARBITER_DATA_1_AND_ARBITER_DATA_2 - # ): - # sc_obj.get_out_of_quorum_nodes() - # check for ceph accessibility and note the end time (UTC) timeout = (end_time - datetime.now(timezone.utc)).total_seconds() if not sc_obj.check_ceph_accessibility(timeout=timeout):