fix odf delete disk (#706)

Author: ebattat

benchmark_runner/common/oc/oc.py

@@ -100,6 +100,16 @@ def get_free_disk_id(self):
         else:
             raise Exception('Missing free disk id')
 
+    @typechecked
+    def run_debug_node(self, node: str, cmd: str):
+        """
+        This method runs command in debug node
+        :param: node
+        :param: cmd
+        :return:
+        """
+        self.run(f"{self.__cli} debug node/{node} --no-tty=true -- chroot /host sh -c '{cmd}'")
+
     def get_kata_operator_version(self):
         """
         This method returns kata operator version

benchmark_runner/common/ocp_resources/create_odf.py

@@ -35,7 +35,7 @@ def create_odf(self):
                         for disk_id in disk_ids:
                             disk = f'/dev/disk/by-id/{self.__worker_disk_prefix}{disk_id}'
                             delete_node_disk += f"sgdisk --zap-all {disk}; wipefs -a {disk}; dd if=/dev/zero of='{disk}' bs=1M count=100 oflag=direct,dsync; blkdiscard {disk}; partprobe {disk};"
-                        self.__oc.run(cmd=f'chmod +x {os.path.join(self.__path, resource)}; {self.__path}/./{resource} "{node}" "{delete_node_disk}"')
+                        self.__oc.run_debug_node(node=node, cmd=delete_node_disk)
                         delete_node_disk = ''
                 else:
                     self.__oc.run(cmd=f'chmod +x {os.path.join(self.__path, resource)}; {self.__path}/./{resource}')
@@ -72,7 +72,4 @@ def create_odf(self):
                     self.wait_for_ocp_resource_create(resource='odf',
                                                       verify_cmd='oc get pod -n openshift-storage | grep osd | grep -v prepare | wc -l',
                                                       count_openshift_storage=True, verify_installation=True)
-            # @todo - remove if not solve ODF installation failure
-            logger.info(f"sleep {self._environment_variables_dict.get('bulk_sleep_time', '')} seconds")
-            time.sleep(int(self._environment_variables_dict.get('bulk_sleep_time', '')))
         return True