running_version.py 文件源码

def run(self):
        data = cluster_data.ClusterData.find_one(self.cluster.model_id)
        cluster_name = data.global_vars.get("cluster", self.cluster.name)
        cluster_name = shlex.quote(cluster_name)

        version_result = await self.execute_cmd(
            "ceph --cluster {0} version".format(cluster_name),
            *self.cluster.server_list)

        self.manage_errors(
            "Cannot execute ceph version command on %s (%s): %s",
            "Not all hosts have working ceph command",
            version_result.errors
        )

        results = list(parse_results(version_result.ok))
        self.manage_versions(results)
        self.manage_commits(results)