]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
qa/tasks/nvmeof.py: Add teardown() method
authorVallari Agrawal <vallari.agrawal@ibm.com>
Wed, 29 Jan 2025 15:34:04 +0000 (21:04 +0530)
committerVallari Agrawal <vallari.agrawal@ibm.com>
Thu, 30 Jan 2025 12:17:00 +0000 (17:47 +0530)
Add teardown method to remove nvmeof service
before rest of the cluster tearsdown.

Signed-off-by: Vallari Agrawal <vallari.agrawal@ibm.com>
qa/tasks/nvmeof.py

index a69c30af26b94813e22a020a64ffc5efd0a71553..1edafb1f41451ab1731cd91cd88b0d94341bea5c 100644 (file)
@@ -209,6 +209,22 @@ class Nvmeof(Task):
         if self.create_mtls_secrets: 
             self.write_mtls_config(gateway_ips)
         log.info("[nvmeof]: executed set_gateway_cfg successfully!")
+    
+    def teardown(self):
+        log.info("[nvmeof] Removing nvmeof service")
+        _shell(self.ctx, self.cluster_name, self.remote, [
+            'ceph', 'orch', 'host', 'ls'
+        ])
+        for i in range(self.groups_count):
+            group_name = self.groups_prefix + str(i)
+            service_name = f"nvmeof.{self.poolname}.{group_name}"
+            _shell(self.ctx, self.cluster_name, self.remote, [
+                'ceph', 'orch', 'rm', service_name
+            ])
+        _shell(self.ctx, self.cluster_name, self.remote, [
+            'ceph', 'orch', 'host', 'ls'
+        ])
+        log.info("[nvmeof] Nvmeof teardown completed!")
 
 
 class NvmeofThrasher(Thrasher, Greenlet):
@@ -542,6 +558,9 @@ class ThrashTest(Nvmeof):
         self.thrasher.join()
         log.info('done joining')
 
+    def teardown(self):
+        log.info('tearing down nvmeof thrasher...')
+
 
 task = Nvmeof
 thrash = ThrashTest