repo_source.py 文件源码

def get_repo_line(result):
    stdout = (line.strip() for line in result.stdout_lines)
    stdout = itertools.dropwhile(lambda item: not item.startswith("***"),
                                 stdout)
    stdout = list(stdout)

    if not stdout:
        raise ValueError("Server {0} has no installed ceph-common".format(
            result.srv.ip))

    yield result.srv, stdout[1].split(" ", 1)[1]