Method run_cluster_cmd

qa/tasks/ceph_manager.py:1671–1704

Run a Ceph command and return the object representing the process for the command. Accepts arguments same as that of teuthology.orchestra.run.run()

(self, **kwargs)

        return self.run_cluster_cmd(args=args, stdout=stdout, stderr=stderr, **kwargs)

    def run_cluster_cmd(self, **kwargs):
        """
        Run a Ceph command and return the object representing the process
        for the command.

        Accepts arguments same as that of teuthology.orchestra.run.run()
        """
        if isinstance(kwargs['args'], str):
            kwargs['args'] = shlex.split(kwargs['args'])
        elif isinstance(kwargs['args'], tuple):
            kwargs['args'] = list(kwargs['args'])

        prefixcmd = []
        timeoutcmd = kwargs.pop('timeoutcmd', None)
        if timeoutcmd is not None:
            prefixcmd += ['timeout', str(timeoutcmd)]

        if self.cephadm:
            prefixcmd += ['ceph']
            cmd = prefixcmd + list(kwargs['args'])
            return shell(self.ctx, self.cluster, self.controller,
                         args=cmd,
                         stdout=StringIO(),
                         check_status=kwargs.get('check_status', True))
        elif self.rook:
            prefixcmd += ['ceph']
            cmd = prefixcmd + list(kwargs['args'])
            return toolbox(self.ctx, self.cluster,
                           args=cmd,
                           stdout=StringIO(),
                           check_status=kwargs.get('check_status', True))
        else:
            kwargs['args'] = prefixcmd + self.get_ceph_cmd(**kwargs) + kwargs['args']
            return self.controller.run(**kwargs)

    def raw_cluster_cmd(self, *args, **kwargs) -> str:
        """