import_ceph.py

VERSION_TABLE = {
    0.80: 'firefly',  # LTS
    0.87: 'giant',
    0.94: 'hammer',  # LTS
    9.2:  'infernalis',
    10.2: 'jewel',  # LTS
}

def import_ceph_api():
    """
    This will import the correct ceph_api version that matches the
    running ceph version.
    """
    ceph_version = get_version()
    if ceph_version in VERSION_TABLE:
        version = VERSION_TABLE[ceph_version]
        log("Importing module ceph_api.{version}.ceph_command".format(
            version=version), level=DEBUG)
        importlib.import_module(
            "ceph_api.{version}.ceph_command".format(version=version))
    else:
        log("Unable to import ceph_api library for version: {}".format(
            ceph_version), level=ERROR)
        raise ImportError